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

Prepend ns

Browse Source
This commit is contained in:
Nuno Campos
2024-10-30 14:09:43 -07:00
parent 9c41ce0b1c
commit 5cb6ff79ca
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/pregel/remote.py
+10 -1
View File
@@ -31,7 +31,12 @@ from langgraph_sdk.schema import StreamMode as StreamModeSDK
from typing_extensions import Self
from langgraph.checkpoint.base import CheckpointMetadata
from langgraph.constants import CONF, CONFIG_KEY_STREAM, INTERRUPT
from langgraph.constants import (
CONF,
CONFIG_KEY_CHECKPOINT_NS,
CONFIG_KEY_STREAM,
INTERRUPT,
)
from langgraph.errors import GraphInterrupt
from langgraph.pregel.protocol import PregelProtocol
from langgraph.pregel.types import All, PregelTask, StateSnapshot, StreamMode
@@ -584,6 +589,8 @@ class RemoteGraph(PregelProtocol):
ns = tuple(ns_.split("|"))
else:
mode, ns = chunk.event, ()
if caller_ns := (config or {}).get(CONF, {}).get(CONFIG_KEY_CHECKPOINT_NS):
ns = caller_ns + ns
if stream is not None and chunk.event in stream.modes:
stream((ns, mode, chunk.data))
if chunk.event not in stream_modes:
@@ -664,6 +671,8 @@ class RemoteGraph(PregelProtocol):
ns = tuple(ns_.split("|"))
else:
mode, ns = chunk.event, ()
if caller_ns := (config or {}).get(CONF, {}).get(CONFIG_KEY_CHECKPOINT_NS):
ns = caller_ns + ns
if stream is not None and chunk.event in stream.modes:
stream((ns, mode, chunk.data))
if chunk.event not in stream_modes: