Compiles the `StateGraph` into a `CompiledStateGraph` object. The compiled graph implements the `Runnable` interface and can be invoked,

Add a new node to the `StateGraph`, input schema is inferred as the state schema. Will take the name of the function/runnable as the node nam

Add a directed edge from the start node (or list of start nodes) to the end node. When a single start node is provided, the graph will wait f

Send `run.start` to the server. Returns the result (`{"run_id": ...}`).

Get a run. Args: thread_id: The thread ID to get. run_id: The run ID to get. headers: Optional custom hea

Block until a run is done. Returns the final state of the thread. Args: thread_id: The thread ID to join. run_id: The

Delete the cached values for the given namespaces. If no namespaces are provided, clear all cached values.

Execute tool with given request. Can be called multiple times.

Route an event through all transformers, then append to the main log. Each transformer's `process()` is called in registration order.

Open a v3 thread-centric streaming session. When `thread_id` is None, a fresh UUIDv4 is minted client-side and included in the URL of

Live state-snapshot projection (mirrors local `run.values`).

Lifecycle event with `event="completed"`.

Get the current state of the graph.

Specifies the first node to be called in the graph. Equivalent to calling `add_edge(START, key)`. Parameters: key (str):

Set the events the next /stream/events calls will replay.

Add a conditional edge from the starting node to any number of destination nodes. Args: source: The starting node. This condition

Get the cached values for the given keys.

Validate a configuration dictionary.

Lifecycle event with `event="started"`.

Create a RunnableConfig targeting a specific thread / namespace / checkpoint.

Get the cached values for the given keys.

Save a checkpoint to the database asynchronously. Note: This async method is not supported by the SqliteSaver class.

Interrupt the graph with a resumable exception from within a node. The `interrupt` function enables human-in-the-loop workflows by pausing graph

Get the history of the state of the graph.

Encode a value for safe interpolation into a request path segment. Path segments are encoded with ``safe=""`` so that ``/`` and other reserved

Get the current state of the graph.

Create a new SqliteStore instance from a connection string. Args: conn_string (str): The SQLite connection string. in

Open a v3 thread-centric streaming session. Args: thread_id: optional explicit thread identifier. Defaults to a f

Create CheckpointMetadata with defaults.

Marks a node as a finish point of the graph. If the graph reaches this node, it will cease execution. Parameters: key (s

Asynchronously get the history of the state of the graph.

Update the state of the graph with the given values, as if they came from node `as_node`. If `as_node` is not provided, it will be set to the

Create a well-formed Checkpoint with sensible defaults.

Set the cached values for the given keys and TTLs.

Finalize all transformers, close all projections and the main log. StreamChannels discovered in transformer projections are auto-clos

Search for items within a namespace prefix. Args: namespace_prefix: Hierarchical path prefix to search within. query:

Creates an agent graph that calls tools in a loop until a stopping condition is met. !!! warning This function is deprecated in favor of

Get a checkpoint tuple from the database asynchronously. Note: This async method is not supported by the SqliteSaver class.

Save a checkpoint to the database. This method saves a checkpoint to the SQLite database. The checkpoint is associated with the provi

Add channel writes. Args: *channels: Channel names to write to. **kwargs: Channel name and value mappings. R

Asynchronously update the state of the graph with the given values, as if they came from node `as_node`. If `as_node` is not provided, it will

Adds the specified node.

Subscribe to a single channel.

Get a run. Args: thread_id: The thread ID to cancel. run_id: The run ID to cancel. wait: Whether to wait

Bind this channel to sync or async mode. Called by the StreamMux after transformer registration. Must be called exactly once before a

List checkpoints from the database asynchronously. Note: This async method is not supported by the SqliteSaver class.

Asynchronously search for items within a namespace prefix. Args: namespace_prefix: Hierarchical path prefix to search within.

Warning nested under a step. Text mode indents; JSON mode strips leading whitespace.

Return a config with all keys, merging any provided configs. Args: *configs: Configs to merge before ensuring defaults. Returns:

Run a task asynchronously with retries.

Return a drawable representation of the computation graph.

Save a checkpoint to the database. This method saves a checkpoint to the Postgres database. The checkpoint is associated with the pro

Store a `ThreadState`-shaped dict for GET /threads/{thread_id}/state.

Merge multiple configs into one. Args: *configs: The configs to merge. Returns: RunnableConfig: The merged config.

Create a RunnableConfig with mock Runtime for testing ToolNode. Returns: RunnableConfig with __pregel_runtime in configurable dict.

Create a human message with an any id field.

Assert a v2 stream part has the required keys and correct types.

Send a `POST` request.

Force projection logs to accept pushes (skip lazy-subscribe gate).

Save a checkpoint to the database asynchronously. This method saves a checkpoint to the Postgres database. The checkpoint is associated

Get a checkpoint tuple from the in-memory storage. This method retrieves a checkpoint tuple from the in-memory storage based on the p

Print a section header for script output.

Build a `tasks` ProtocolEvent carrying a TaskPayload (start).