mirror of
https://github.com/langchain-ai/langgraph.git
synced 2026-10-17 05:35:31 +02:00
b647dcb0f2
Co-authored-by: Erick Friis <erick@langchain.dev> Co-authored-by: vbarda <vadym@langchain.dev>
113 lines
3.1 KiB
Python
113 lines
3.1 KiB
Python
from enum import Enum
|
|
from typing import Any, Sequence
|
|
|
|
from langgraph.checkpoint.base import EmptyChannelError # noqa: F401
|
|
from langgraph.types import Interrupt
|
|
|
|
# EmptyChannelError re-exported for backwards compatibility
|
|
|
|
|
|
class ErrorCode(Enum):
|
|
GRAPH_RECURSION_LIMIT = "GRAPH_RECURSION_LIMIT"
|
|
INVALID_CONCURRENT_GRAPH_UPDATE = "INVALID_CONCURRENT_GRAPH_UPDATE"
|
|
INVALID_GRAPH_NODE_RETURN_VALUE = "INVALID_GRAPH_NODE_RETURN_VALUE"
|
|
MULTIPLE_SUBGRAPHS = "MULTIPLE_SUBGRAPHS"
|
|
|
|
|
|
def create_error_message(*, message: str, error_code: ErrorCode) -> str:
|
|
return (
|
|
f"{message}\n"
|
|
"For troubleshooting, visit: https://python.langchain.com/docs/"
|
|
f"troubleshooting/errors/{error_code.value}"
|
|
)
|
|
|
|
|
|
class GraphRecursionError(RecursionError):
|
|
"""Raised when the graph has exhausted the maximum number of steps.
|
|
|
|
This prevents infinite loops. To increase the maximum number of steps,
|
|
run your graph with a config specifying a higher `recursion_limit`.
|
|
|
|
Troubleshooting Guides:
|
|
|
|
- [GRAPH_RECURSION_LIMIT](https://python.langchain.com/docs/troubleshooting/errors/GRAPH_RECURSION_LIMIT)
|
|
|
|
Examples:
|
|
|
|
graph = builder.compile()
|
|
graph.invoke(
|
|
{"messages": [("user", "Hello, world!")]},
|
|
# The config is the second positional argument
|
|
{"recursion_limit": 1000},
|
|
)
|
|
"""
|
|
|
|
pass
|
|
|
|
|
|
class InvalidUpdateError(Exception):
|
|
"""Raised when attempting to update a channel with an invalid set of updates.
|
|
|
|
Troubleshooting Guides:
|
|
|
|
- [INVALID_CONCURRENT_GRAPH_UPDATE](https://python.langchain.com/docs/troubleshooting/errors/INVALID_CONCURRENT_GRAPH_UPDATE)
|
|
- [INVALID_GRAPH_NODE_RETURN_VALUE](https://python.langchain.com/docs/troubleshooting/errors/INVALID_GRAPH_NODE_RETURN_VALUE)
|
|
"""
|
|
|
|
pass
|
|
|
|
|
|
class GraphInterrupt(Exception):
|
|
"""Raised when a subgraph is interrupted, suppressed by the root graph.
|
|
Never raised directly, or surfaced to the user."""
|
|
|
|
def __init__(self, interrupts: Sequence[Interrupt] = ()) -> None:
|
|
super().__init__(interrupts)
|
|
|
|
|
|
class NodeInterrupt(GraphInterrupt):
|
|
"""Raised by a node to interrupt execution."""
|
|
|
|
def __init__(self, value: Any) -> None:
|
|
super().__init__([Interrupt(value)])
|
|
|
|
|
|
class GraphDelegate(Exception):
|
|
"""Raised when a graph is delegated (for distributed mode)."""
|
|
|
|
def __init__(self, *args: dict[str, Any]) -> None:
|
|
super().__init__(*args)
|
|
|
|
|
|
class EmptyInputError(Exception):
|
|
"""Raised when graph receives an empty input."""
|
|
|
|
pass
|
|
|
|
|
|
class TaskNotFound(Exception):
|
|
"""Raised when the executor is unable to find a task (for distributed mode)."""
|
|
|
|
pass
|
|
|
|
|
|
class CheckpointNotLatest(Exception):
|
|
"""Raised when the checkpoint is not the latest version (for distributed mode)."""
|
|
|
|
pass
|
|
|
|
|
|
class MultipleSubgraphsError(Exception):
|
|
"""Raised when multiple subgraphs are called inside the same node.
|
|
|
|
Troubleshooting guides:
|
|
|
|
- [MULTIPLE_SUBGRAPHS](https://python.langchain.com/docs/troubleshooting/errors/MULTIPLE_SUBGRAPHS)
|
|
"""
|
|
|
|
pass
|
|
|
|
|
|
_SEEN_CHECKPOINT_NS: set[str] = set()
|
|
"""Used for subgraph detection."""
|