WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-30 05:25:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor(langgraph): make _prepare_state_snapshot recurse a bool

Browse Source 
recurse only ever carried the same saver as saver, or None. Take a flag and
hand saver to the child's CONFIG_KEY_CHECKPOINTER, so the snapshot helpers
hold the saver in one argument.
This commit is contained in:
Elior Nataf Lackritz
2026-09-28 16:30:32 -04:00
parent 23331a8389
commit c9d5d5b317
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/main.py
+6 -6
View File
@@ -1148,7 +1148,7 @@ class Pregel(
saved: CheckpointTuple | None,
*,
saver: BaseCheckpointSaver,
recurse: BaseCheckpointSaver | None = None,
recurse: bool = False,
apply_pending_writes: bool = False,
) -> StateSnapshot:
if not saved:
@@ -1213,7 +1213,7 @@ class Pregel(
# get the state of the subgraph
config = {
CONF: {
CONFIG_KEY_CHECKPOINTER: recurse,
CONFIG_KEY_CHECKPOINTER: saver,
"thread_id": saved.config[CONF]["thread_id"],
CONFIG_KEY_CHECKPOINT_NS: task_ns,
}
@@ -1267,7 +1267,7 @@ class Pregel(
saved: CheckpointTuple | None,
*,
saver: BaseCheckpointSaver,
recurse: BaseCheckpointSaver | None = None,
recurse: bool = False,
apply_pending_writes: bool = False,
) -> StateSnapshot:
if not saved:
@@ -1332,7 +1332,7 @@ class Pregel(
# get the state of the subgraph
config = {
CONF: {
CONFIG_KEY_CHECKPOINTER: recurse,
CONFIG_KEY_CHECKPOINTER: saver,
"thread_id": saved.config[CONF]["thread_id"],
CONFIG_KEY_CHECKPOINT_NS: task_ns,
}
@@ -1422,7 +1422,7 @@ class Pregel(
config,
saved,
saver=checkpointer,
recurse=checkpointer if subgraphs else None,
recurse=subgraphs,
apply_pending_writes=CONFIG_KEY_CHECKPOINT_ID not in config[CONF],
)
@@ -1467,7 +1467,7 @@ class Pregel(
config,
saved,
saver=checkpointer,
recurse=checkpointer if subgraphs else None,
recurse=subgraphs,
apply_pending_writes=CONFIG_KEY_CHECKPOINT_ID not in config[CONF],
)