diff --git a/libs/langgraph/langgraph/pregel/__init__.py b/libs/langgraph/langgraph/pregel/__init__.py index ed3ec185a..4ef53b40f 100644 --- a/libs/langgraph/langgraph/pregel/__init__.py +++ b/libs/langgraph/langgraph/pregel/__init__.py @@ -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)