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

skip yielding interrupt if input was a map

Browse Source
This commit is contained in:
Sydney Runkle
2025-04-28 11:47:51 -04:00
parent dbf1c28ccd
commit 5fee0d9d66
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/loop.py
+10 -8
View File
@@ -650,19 +650,21 @@ class PregelLoop(LoopProtocol):
# map command to writes
if isinstance(self.input, Command):
if (resume := self.input.resume) is not None:
if isinstance(resume, dict) and all(
is_xxh3_128_hexdigest(k) for k in resume
):
self.config[CONF][CONFIG_KEY_RESUME_MAP] = self.input.resume
if self.input.resume is not None and not self.checkpointer:
if resume_is_map := (
(resume := self.input.resume) is not None
and isinstance(resume, dict)
and all(is_xxh3_128_hexdigest(k) for k in resume)
):
self.config[CONF][CONFIG_KEY_RESUME_MAP] = self.input.resume
if resume is not None and not self.checkpointer:
raise RuntimeError(
"Cannot use Command(resume=...) without checkpointer"
)
writes: defaultdict[str, list[tuple[str, Any]]] = defaultdict(list)
# group writes by task ID
for tid, c, v in map_command(self.input):
writes[tid].append((c, v))
for tid, c, v in map_command(cmd=self.input):
if not (c == RESUME and resume_is_map):
writes[tid].append((c, v))
if not writes:
raise EmptyInputError("Received empty Command input")
# save writes