This commit is contained in:
Nuno Campos
2024-11-04 16:43:07 -08:00
parent 04657408f8
commit dec0b7f439
@@ -877,7 +877,6 @@ class Pregel(PregelProtocol):
# tasks for this checkpoint
next_tasks = prepare_next_tasks(
checkpoint,
saved.pending_writes or [],
self.nodes,
channels,
managed,
@@ -1061,7 +1060,6 @@ class Pregel(PregelProtocol):
# tasks for this checkpoint
next_tasks = prepare_next_tasks(
checkpoint,
saved.pending_writes or [],
self.nodes,
channels,
managed,