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

Remove dict

Browse Source
This commit is contained in:
Tat Dat Duong
2025-06-26 01:30:10 +02:00
parent 263a583f01
commit adb2eee54b
1 changed files with 11 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/__init__.py
+11 -19
View File
@@ -219,9 +219,9 @@ class NodeBuilder:
*channels: str,
) -> Self:
"""Adds the specified channels to read from, without subscribing to them."""
assert isinstance(self._channels, list), (
"Cannot read additional channels when subscribed to single channels"
)
assert isinstance(
self._channels, list
), "Cannot read additional channels when subscribed to single channels"
self._channels.extend(channels)
return self
@@ -1421,7 +1421,7 @@ class Pregel(PregelProtocol[StateT, InputT, OutputT], Generic[StateT, InputT, Ou
self.channels,
checkpoint,
)
values, as_node, _ = updates[0]
values, as_node = updates[0][:2]
# no values as END, just clear all tasks
if values is None and as_node == END:
@@ -1594,17 +1594,13 @@ class Pregel(PregelProtocol[StateT, InputT, OutputT], Generic[StateT, InputT, Ou
tasks_group_by[task.name].append(task.id)
for item in values:
if isinstance(item, dict):
values = item["values"]
as_node = item["as_node"]
elif isinstance(item, StateUpdate):
values = item.values
as_node = item.as_node
else:
if not isinstance(item, Sequence):
raise InvalidUpdateError(
f"Invalid update item: {item} when copying checkpoint"
)
values, as_node = item[:2]
user_group = user_group_by[as_node]
tasks_group = tasks_group_by[as_node]
@@ -1880,7 +1876,7 @@ class Pregel(PregelProtocol[StateT, InputT, OutputT], Generic[StateT, InputT, Ou
self.channels,
checkpoint,
)
values, as_node, _ = updates[0]
values, as_node = updates[0][:2]
# no values, just clear all tasks
if values is None and as_node == END:
if len(updates) > 1:
@@ -2012,6 +2008,7 @@ class Pregel(PregelProtocol[StateT, InputT, OutputT], Generic[StateT, InputT, Ou
raise InvalidUpdateError("Cannot copy a non-existent checkpoint")
next_checkpoint = create_checkpoint(checkpoint, None, step)
# copy checkpoint
next_config = await checkpointer.aput(
saved.parent_config
@@ -2050,17 +2047,12 @@ class Pregel(PregelProtocol[StateT, InputT, OutputT], Generic[StateT, InputT, Ou
tasks_group_by[task.name].append(task.id)
for item in values:
if isinstance(item, dict):
values = item["values"]
as_node = item["as_node"]
elif isinstance(item, StateUpdate):
values = item.values
as_node = item.as_node
else:
if not isinstance(item, Sequence):
raise InvalidUpdateError(
f"Invalid update item: {item} when copying checkpoint"
)
values, as_node = item[:2]
user_group = user_group_by[as_node]
tasks_group = tasks_group_by[as_node]