Send a `GET` request.

Return cached annotated keys for a Python class.

Determine the default value for a field in a state schema. This is based on: If TypedDict: - Required/NotRequired

Get graph by graph name. This method calls `GET /assistants/{assistant_id}/graph`. Args: config: This parameter is not u

Get the graph of an assistant by ID. Args: assistant_id: The ID of the assistant to get the graph of. xray: Include g

Retrieve a single item. Args: key: The unique identifier for the item. namespace: Optional list of strings representi

Get the schemas of an assistant by ID. Args: assistant_id: The ID of the assistant to get the schema of. headers: Opt

Get the state of a thread. This method calls `POST /threads/{thread_id}/state/checkpoint` if a checkpoint is specified in the config

Fetch a checkpoint tuple using the given configuration. Args: config: Configuration specifying which checkpoint to retrieve.

Get Pydantic state update as a list of (key, value) tuples.

Channel names written by an update_state superstep (excluding PUSH).

Check if a function is an async generator.

List namespaces with optional match conditions. Args: prefix: Optional list of strings representing the prefix to filter namespac

Folds task writes into a result dict and aggregates multiple writes to the same channel. If the channel contains a single write, we record the wr

Wrap serde old serde implementations in a class with loads_typed and dumps_typed for backwards compatibility.

Convert tool output to `ToolMessage` content format. Handles `str`, `list[dict]` (content blocks), and arbitrary objects by attempting JSON s

Advance the reconnect cursor from a command response meta sequence.

Run when graph execution pauses due to one or more interrupts. Args: event: Interrupt lifecycle event payload.

Run when graph execution resumes from a persisted checkpoint. Args: event: Resume lifecycle event payload.

Fetch terminal thread state (blocking); waits for lifecycle completion. Raises: RuntimeError: stream not entered, or no run start

Whether all base capability tests passed.

Return a new runtime with selected execution_info fields replaced.

Prepares a single task for the next Pregel step, given a task path, which uniquely identifies a PUSH or PULL task within the graph.

Handle an event on the sync lane. Called for every event before it is appended to the main event log. Subclasses must override either

Send a `PUT` request.

Register a listener for serde allowlist events.

Run the full sweep and return all measurement rows.

Submit a coroutine object to a given event loop. Return an asyncio.Future to access the result.

Pop any values belonging to UntrackedValue channels in Send.arg for safe checkpointing. Send is often called with state to be passed to the dest

Search for items within a namespace prefix. Args: namespace_prefix: List of strings representing the namespace prefix.

Set the cached values for the given keys and TTLs.

Check if the graph should be interrupted based on current state.

Wake every active subscription iterator on interrupt (run pause). Pushes the terminal sentinel (`None`) into every subscription queue.

Periodically delete expired store items based on TTL. Returns: Future that can be waited on or cancelled.

Process one streamed stage-1 row in the merged ancestor walk. The cursor returns (cid, parent_cid, type, blob) rows in `checkpoint_id` DESC o

Execute a single iteration of the Pregel loop. Returns: True if more iterations are needed.

Update an assistant. Use this to point to a different graph, update the configuration, or change the metadata of an assistant. Args:

Update an assistant. Use this to point to a different graph, update the configuration, or change the metadata of an assistant. Args:

Update the state of a thread. This method calls `POST /threads/{thread_id}/state`. Args: config: A `RunnableConfig` that

Reject reserved protocol channel names before they hit the fallback. Genuine extension names pass through untouched; only names that ``infer_

The type of the value stored in the channel.

Configure the handler to stream messages from LLMs and nodes. Args: stream: A callable that takes a StreamChunk and emits it.

Initialize `ToolNode` with tools and configuration. Args: tools: Sequence of tools to make available for execution. n

Subscribe and return a sync cursor. Can be called only once. Raises: TypeError: If the channel is unbound or bound to async mode.

Raise deprecation warning when setting attributes directly. Direct attribute assignment is deprecated. Use the `override()` method instead.

Create the root-scope messages inbox if not already active and return it. Called by `_SubgraphsProjection` at scope `()` to capture messages