x

2026-09-02 14:08:42 +02:00 · 2025-01-16 13:55:41 -05:00
parent 3095bfce9c
commit 421f7c0238
1 changed files with 2 additions and 2 deletions
@@ -345,11 +345,11 @@ class PregelLoop(LoopProtocol):
                (PUSH, task.path, write_idx, task.id, call),
                None,
                checkpoint=self.checkpoint,
-                pending_writes=[(task.id, *w) for w in task.writes],
+                pending_writes=self.checkpoint_pending_writes,
                processes=self.nodes,
                channels=self.channels,
                managed=self.managed,
-                config=self.config,
+                config=task.config,
                step=self.step,
                for_execution=True,
                store=self.store,