remove futures.clear

2026-09-09 19:27:54 +02:00 · 2024-08-21 18:26:54 -04:00
parent 578ec48031
commit 0b6088f913
1 changed files with 0 additions and 3 deletions
@@ -1185,8 +1185,6 @@ class Pregel(
                                else:
                                    loop.put_writes(task.id, [(ERROR, exc)])

-                                futures.clear()
-
                            else:
                                # save task writes to checkpointer
                                loop.put_writes(task.id, task.writes)
@@ -1447,7 +1445,6 @@ class Pregel(
                                else:
                                    loop.put_writes(task.id, [(ERROR, exc)])

-                                futures.clear()
                            else:
                                # save task writes to checkpointer
                                loop.put_writes(task.id, task.writes)