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

Fix

Browse Source
This commit is contained in:
Nuno Campos
2024-10-14 17:16:32 -07:00
parent 5e175e098b
commit d48faecd42
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/__init__.py
+6 -6
View File
@@ -437,8 +437,8 @@ class Pregel(Runnable[Union[dict[str, Any], Any], Union[dict[str, Any], Any]]):
saved.checkpoint,
LoopProtocol(
config=saved.config,
step=saved.metadata["step"],
stop=saved.metadata["step"] + 1,
step=saved.metadata.get("step", -1) + 1,
stop=saved.metadata.get("step", -1) + 2,
),
skip_context=True,
) as (channels, managed):
@@ -522,8 +522,8 @@ class Pregel(Runnable[Union[dict[str, Any], Any], Union[dict[str, Any], Any]]):
saved.checkpoint,
LoopProtocol(
config=saved.config,
step=saved.metadata["step"],
stop=saved.metadata["step"] + 1,
step=saved.metadata.get("step", -1) + 1,
stop=saved.metadata.get("step", -1) + 2,
),
skip_context=True,
) as (
@@ -852,7 +852,7 @@ class Pregel(Runnable[Union[dict[str, Any], Any], Union[dict[str, Any], Any]]):
with ChannelsManager(
self.channels,
checkpoint,
LoopProtocol(config=config, step=step, stop=step + 1),
LoopProtocol(config=config, step=step + 1, stop=step + 2),
) as (
channels,
managed,
@@ -1002,7 +1002,7 @@ class Pregel(Runnable[Union[dict[str, Any], Any], Union[dict[str, Any], Any]]):
async with AsyncChannelsManager(
self.channels,
checkpoint,
LoopProtocol(config=config, step=step, stop=step + 1),
LoopProtocol(config=config, step=step + 1, stop=step + 2),
) as (
channels,
managed,
libs/scheduler-kafka/langgraph/scheduler/kafka/executor.py
-1
View File
@@ -191,7 +191,6 @@ class AsyncKafkaExecutor(AbstractAsyncContextManager):
step=saved.metadata["step"] + 1,
stop=saved.metadata["step"] + 2,
),
self.graph.store,
) as (channels, managed), AsyncBackgroundExecutor() as submit:
if task := await asyncio.to_thread(
prepare_single_task,