This commit is contained in:
Nuno Campos
2024-12-04 15:39:16 -08:00
parent 9733db03c5
commit de86a46b3d
@@ -133,6 +133,8 @@ class PregelRunner:
CONFIG_KEY_CALL: partial(call, next_task),
},
__reraise_on_exit__=reraise,
# starting a new task in the next tick ensures
# updates from this tick are committed/streamed first
__next_tick__=True,
)
fut.add_done_callback(partial(self.commit, next_task))
@@ -319,6 +321,9 @@ class PregelRunner:
__name__=t.name,
__cancel_on_exit__=True,
__reraise_on_exit__=reraise,
# starting a new task in the next tick ensures
# updates from this tick are committed/streamed first
__next_tick__=True,
),
)
fut.add_done_callback(partial(self.commit, next_task))