One more

2026-09-07 02:07:52 +02:00 · 2025-03-18 09:34:52 -07:00
parent 98b8ff904c
commit fa96c0ac76
1 changed files with 4 additions and 0 deletions
@@ -210,6 +210,10 @@ class AsyncKafkaExecutor(AbstractAsyncContextManager):
                for_execution=True,
                checkpointer=self.graph.checkpointer,
                store=self.graph.store,
+                checkpoint_id_bytes=binascii.unhexlify(
+                    saved.checkpoint["id"].replace("-", "")
+                ),
+                checkpoint_null_version=checkpoint_null_version(saved.checkpoint),
            ):
                # execute task, saving writes
                runner = PregelRunner(