fix: ensure finalise transactions

vegaprotocol · Jun 25, 2024 · 2681352 · 2681352
1 parent 986c249
commit 2681352
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/vega_sim/environment/environment.py b/vega_sim/environment/environment.py
@@ -289,6 +289,10 @@ def _run(
             )
         for agent in self.agents:
             agent.finalise()
+        # Forward a number of transactions so finalise transactions can occur
+        for _ in range(60):
+            vega.wait_fn(1)
+            vega.wait_for_total_catchup()
         vega.wait_for_core_catchup()
         vega.wait_for_datanode_sync()
 
@@ -521,6 +525,10 @@ def _run(
                     raise (e)
                 else:
                     logging.warning(msg)
+        # Forward a number of transactions so finalise transactions can occur
+        for _ in range(60):
+            vega.wait_fn(1)
+            vega.wait_for_total_catchup()
         if pause_at_completion:
             input(
                 "Environment run completed. Pausing to allow inspection of state."