If FuturesDict callback has been GCed, don't call it

This commit is contained in:
Nuno Campos
2025-06-17 13:47:47 -07:00
parent 1309243b29
commit 6dcff8a839
4 changed files with 5 additions and 4 deletions
+1 -1
View File
@@ -308,7 +308,7 @@ wheels = [
[[package]]
name = "langgraph-checkpoint"
version = "2.0.26"
version = "2.1.0"
source = { editable = "../checkpoint" }
dependencies = [
{ name = "langchain-core" },
+1 -1
View File
@@ -320,7 +320,7 @@ wheels = [
[[package]]
name = "langgraph-checkpoint"
version = "2.0.26"
version = "2.1.0"
source = { editable = "../checkpoint" }
dependencies = [
{ name = "langchain-core" },
+2 -1
View File
@@ -104,7 +104,8 @@ class FuturesDict(Generic[F, E], dict[F, Optional[PregelExecutableTask]]):
fut: F,
) -> None:
try:
self.callback()(task, _exception(fut)) # type: ignore[misc]
if cb := self.callback():
cb(task, _exception(fut))
finally:
with self.lock:
self.done.add(fut)
+1 -1
View File
@@ -320,7 +320,7 @@ wheels = [
[[package]]
name = "langgraph"
version = "0.5.0rc0"
version = "0.5.0rc1"
source = { editable = "../langgraph" }
dependencies = [
{ name = "langchain-core" },