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

Use if_not_exists

Browse Source
This commit is contained in:
Nuno Campos
2024-10-23 13:24:19 -07:00
parent 1121806ba4
commit f8a0b7a464
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/remote.py
+4
View File
@@ -407,6 +407,7 @@ class RemoteGraph(PregelProtocol, Runnable):
interrupt_before=interrupt_before,
interrupt_after=interrupt_after,
stream_subgraphs=subgraphs,
if_not_exists="create",
):
if chunk.event.startswith("updates"):
if isinstance(chunk.data, dict) and INTERRUPT in chunk.data:
@@ -453,6 +454,7 @@ class RemoteGraph(PregelProtocol, Runnable):
interrupt_before=interrupt_before,
interrupt_after=interrupt_after,
stream_subgraphs=subgraphs,
if_not_exists="create",
):
if chunk.event.startswith("updates"):
if isinstance(chunk.data, dict) and INTERRUPT in chunk.data:
@@ -494,6 +496,7 @@ class RemoteGraph(PregelProtocol, Runnable):
config=sanitized_config,
interrupt_before=interrupt_before,
interrupt_after=interrupt_after,
if_not_exists="create",
)
async def ainvoke(
@@ -514,4 +517,5 @@ class RemoteGraph(PregelProtocol, Runnable):
config=sanitized_config,
interrupt_before=interrupt_before,
interrupt_after=interrupt_after,
if_not_exists="create",
)