This remaps fields to avoid colliding with internal pydantic fields.

Resolve the model to use, handling both static and dynamic models.

Return the checkpoint namespace the caller is running under. `stream_events(version="v3")` uses this to scope its native projections (`Values

Convert a row from the database into an Item.

Convert a row from the database into an Item. Args: namespace: Item namespace row: Database row loader: Optional value lo

Convert a row from the database into a SearchItem.

Convert a row from the database into an Item.

Send a protocol command and return the `result` payload. Returns `{}` for 202/204 responses (no body). Raises `RuntimeError` with the

Send a protocol command and return the `result` payload.

Check if any task failed, if so, cancel all other tasks. GraphInterrupts are not considered failures.

Wake every active projection iterator on interrupt / run end. Pushes the terminal sentinel (`None`) into every subscription queue. It

Strips Annotated, Required and NotRequired from a given type.

Advance each not-yet-seeded channel's walk as far as possible. Uses the partial `parent_of` map accumulated so far. A walk stops eith

Validate that all tool calls in AIMessages have a corresponding ToolMessage.

Block until lifecycle completion. Raises: RuntimeError: stream not entered, or no run started and no explicit thr

Install the auto-forward callback (called by StreamMux).

Return the path as it goes on the wire (preserves percent-encoding).

Wrap a raw SSE stream, converting each event to a v2 dict.

Wrap a raw SSE stream, converting each event to a v2 dict.

Accept a PUSH from a task, potentially returning a new task to start.

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

Asynchronously clear the cache for the given nodes.

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

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

Get the state history of a thread. This method calls `POST /threads/{thread_id}/history`. Args: config: A `RunnableConfi

Get a checkpoint tuple from the database asynchronously. This method retrieves a checkpoint tuple from the SQLite database based on the

Asynchronously fetch a checkpoint tuple using the given configuration. Args: config: Configuration specifying which checkpoint to

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

Async counterpart to `bind_pump`.

Demux stage-2 rows per channel; produce per-channel histories. Stage-2 rows are `(checkpoint_id, channel, task_id, idx, type, value)`. Final

Stage-2 per-channel UNION ALL fetching writes from `writes`. One branch per channel with a non-empty chain. Each branch inlines its own `IN (

Build a Docker image from a LangGraph config.

Get the null version for the checkpoint, if available.

Clear the cache for the given nodes.

Tear down the thread stream. Idempotent.

Return a human-readable conformance level string.

Copy a thread. Args: thread_id: The ID of the thread to copy. headers: Optional custom headers to include with the re

Count cron jobs matching filters. Args: assistant_id: Assistant ID to filter by. thread_id: Thread ID to filter by.

Return ``(channels_to_snapshot, metadata)`` for an update_state head.

Create a deployment.

Create a cron job for a thread. Args: thread_id: the thread ID to run the cron job on. assistant_id: The assistant ID

Create a cron job for a thread. Args: thread_id: the thread ID to run the cron job on. assistant_id: The assistant ID

Create a sequential no-op graph consisting of a few hundred nodes.

Delete a cron. Args: cron_id: The cron ID to delete. headers: Optional custom headers to include with the request.

Get the graph for this Pregel instance. Args: config: The configuration to use for the graph. subgraphs: The subgraphs to include

Embed a list of documents.

Embed a list of documents.

Embed a list of texts into vectors. Args: texts: list of texts to convert to embeddings. Returns: list of em

Emit a serde event to all listeners. Listener failures are isolated and logged.

Synthetic task id for exit-mode DeltaChannel writes. Embeds the superstep in the first UUID group so `ORDER BY task_id, idx` preserves chrono

Propagate run error to any streams still open when the graph fails.

Drop langgraph's internal `seq:step:*` bookkeeping tags. `seq:step:N` tags are added internally to mark sequence steps; everything else (user

Called when the run ends normally (sync lane). Override to close StreamChannels, resolve promises, or perform other teardown. StreamC

Return deployment ID for an exact name match, or None if not found.

Return the current value of the channel. Raises `EmptyChannelError` if the channel is empty (never updated yet).

Get the cached values for the given keys.

Send a `GET` request.