Lint

2026-10-01 14:05:10 +02:00 · 2024-11-11 14:14:23 -08:00
parent 0e872e7482
commit 090b53ccc1
1 changed files with 2 additions and 0 deletions
@@ -887,6 +887,7 @@ class Pregel(PregelProtocol):
                    # tasks for this checkpoint
                    next_tasks = prepare_next_tasks(
                        checkpoint,
+                        saved.pending_writes or [],
                        self.nodes,
                        channels,
                        managed,
@@ -1106,6 +1107,7 @@ class Pregel(PregelProtocol):
                    # tasks for this checkpoint
                    next_tasks = prepare_next_tasks(
                        checkpoint,
+                        saved.pending_writes or [],
                        self.nodes,
                        channels,
                        managed,