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

Merge pull request #411 from langchain-ai/nc/7may/fix-recursion-issue

Browse Source 
Fix recursion check
This commit is contained in:
Nuno Campos
2024-05-07 08:33:27 -07:00
committed by GitHub
parent 9d56669ffa f4a4b98946
commit 65dcba2e2a
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
langgraph/pregel/__init__.py
+12 -12
View File
@@ -708,12 +708,6 @@ class Pregel(
raise ValueError("No tasks to run in graph.")
else:
break
elif step == config["recursion_limit"]:
raise GraphRecursionError(
f"Recursion limit of {config['recursion_limit']} reached"
"without hitting a stop condition. You can increase the "
"limit by setting the `recursion_limit` config key."
)
# before execution, check if we should interrupt
if _should_interrupt(
@@ -833,6 +827,12 @@ class Pregel(
next_tasks,
):
break
else:
raise GraphRecursionError(
f"Recursion limit of {config['recursion_limit']} reached"
"without hitting a stop condition. You can increase the "
"limit by setting the `recursion_limit` config key."
)
# set final channel values as run output
run_manager.on_chain_end(read_channels(channels, output_keys))
@@ -976,12 +976,6 @@ class Pregel(
raise ValueError("No tasks to run in graph.")
else:
break
elif step == config["recursion_limit"]:
raise GraphRecursionError(
f"Recursion limit of {config['recursion_limit']} reached"
"without hitting a stop condition. You can increase the limit"
"by setting the `recursion_limit` config key."
)
# before execution, check if we should interrupt
if _should_interrupt(
@@ -1112,6 +1106,12 @@ class Pregel(
next_tasks,
):
break
else:
raise GraphRecursionError(
f"Recursion limit of {config['recursion_limit']} reached"
"without hitting a stop condition. You can increase the limit"
"by setting the `recursion_limit` config key."
)
# set final channel values as run output
await run_manager.on_chain_end(read_channels(channels, output_keys))