This commit is contained in:
Nuno Campos
2024-12-04 15:38:15 -08:00
parent a443b3b256
commit 90dd2b01b6
@@ -248,6 +248,7 @@ class PregelRunner:
# bail if not a PUSH write
if w[0] != PUSH:
continue
# TODO apply changes from sync version
# schedule the next task, if the callback returns one
if next_task := self.schedule_task(
task,