mirror of
https://github.com/langchain-ai/langgraph.git
synced 2026-08-23 16:12:25 +02:00
@@ -1,4 +1,3 @@
|
||||
import warnings
|
||||
from dataclasses import asdict
|
||||
from typing import (
|
||||
Any,
|
||||
@@ -621,13 +620,6 @@ class RemoteGraph(PregelProtocol):
|
||||
stream_mode, config
|
||||
)
|
||||
if isinstance(input, Command):
|
||||
if input.resume and "thread_id" not in sanitized_config["configurable"]:
|
||||
warnings.warn(
|
||||
"Trying to resume interrupted graph without `thread_id` in the config. "
|
||||
"This will likely lead to downstream errors. Please provide a valid config in the following form: "
|
||||
"{'configurable': {'thread_id': '...'}}."
|
||||
)
|
||||
|
||||
command: Optional[CommandSDK] = cast(CommandSDK, asdict(input))
|
||||
input = None
|
||||
else:
|
||||
@@ -723,13 +715,6 @@ class RemoteGraph(PregelProtocol):
|
||||
stream_mode, config
|
||||
)
|
||||
if isinstance(input, Command):
|
||||
if input.resume and "thread_id" not in sanitized_config["configurable"]:
|
||||
warnings.warn(
|
||||
"Trying to resume interrupted graph without `thread_id` in the config. "
|
||||
"This will likely lead to downstream errors. Please provide a valid config in the following form: "
|
||||
"{'configurable': {'thread_id': '...'}}."
|
||||
)
|
||||
|
||||
command: Optional[CommandSDK] = cast(CommandSDK, asdict(input))
|
||||
input = None
|
||||
else:
|
||||
|
||||
Reference in New Issue
Block a user