Format a single log entry for display.

Get a thread by ID. Args: thread_id: The ID of the thread to get. include: Additional fields to include in the respon

Get an async callback manager for a config. Args: config: The config. Returns: AsyncCallbackManager: The async callback mana

Get a callback manager for a config. Args: config: The config. Returns: CallbackManager: The callback manager.

Get the subgraphs of the graph. Args: namespace: The namespace to filter the subgraphs by. recurse: Whether to recurs

Check if a function is async.

Return click color for a log level.

Merge two runtimes together. If a value is not provided in the other runtime, the value from the current runtime is used.

Validate and return a Docker image tag. Tags may only contain [A-Za-z0-9_.-]. Defaults to "latest" when empty.

Public alias for `_reconcile_stream`.

Schedule a coroutine tied to this transformer's lifecycle. The mux holds the task reference, awaits all scheduled tasks during `aclos

Recursively add a directory to the tarball under the given prefix. If arcname_prefix is None, files are added at the archive root. Paths matc

Create a store with vector search enabled.

Create a database cursor as a context manager. Args: pipeline: whether to use pipeline for the DB operations inside the context m

Create a database cursor as a context manager. Args: pipeline: whether to use pipeline for the DB operations inside the context m

Ensure runtime has execution_info, creating one from config if needed. In the distributed runtime (LangGraph Platform), tasks are prepared by the

Helper: build a simple graph that captures runtime info.

Set up a minimal project directory with a config file.

Normalize stream transformer specs to scoped factories. A stream transformer spec is a callable that accepts `scope: tuple[str, ...]` and ret

Put a checkpoint with a run_id in metadata, return stored config.

Sanitize the config to remove non-serializable fields.

Return `[(config, items), ...]` for every checkpoint in `history` whose `next == ('__start__',)` — the stable boundaries between invokes.

Create n checkpoints on tid. Returns stored configs.

Translate a local `Command` into the v3 wire `input`, else passthrough. The v3 server decides start-vs-resume from thread state (an interrupted

Validates that an auth handler function meets the required signature. Auth handlers must: 1. Be async functions 2. Accept a ctx parameter

Ensure a prebuilt image exists locally for linux/amd64.

Async batch operation - not supported in SqliteStore. Use AsyncSqliteStore for async operations.

Asynchronously apply updates to the graph state in bulk. Requires a checkpointer to be set. Args: config: The config to apply the

Asynchronously embed a list of texts into vectors. Args: texts: list of texts to convert to embeddings. Returns:

Fast-path override of `BaseCheckpointSaver.aget_delta_channel_history`. See `PostgresSaver.get_delta_channel_history` for design notes; this

Get the subgraphs of the graph. Args: namespace: The namespace to filter the subgraphs by. recurse: Whether to recurs

Spawn a background task that responds to the first interrupt and exits. Opens a private `thread.values` subscription and drains it; the SDK's

Sync analogue of `auto_respond_async`.

Execute multiple operations synchronously in a single batch. Args: ops: An iterable of operations to execute. Returns:

Build a parent chain with `_DeltaSnapshot` at known positions. Args: saver: Checkpointer instance. thread_id: Defaults to a rando

Hydrate channels from a checkpoint. For most channels, `spec.from_checkpoint(checkpoint["channel_values"][k])` is sufficient. `DeltaChannel`

Convert a v2 StreamPart to a ProtocolEvent. Args: part: A stream part with keys `type`, `ns`, `data`, and optionally `interru

Create a pydantic model with the given field definitions. Attention: Please do not use outside of langchain packages. This API is

Stream a partial output chunk on the `tools` stream channel. Reads the per-tool-call writer that `StreamToolCallHandler` installs on

Convert a timestamp (epoch ms or string) to a readable string.

Get an assistant by ID. Args: assistant_id: The ID of the assistant to get. headers: Optional custom headers to inclu

Get an assistant by ID. Args: assistant_id: The ID of the assistant to get OR the name of the graph (to use the default assistant

Create and configure a LangGraphClient. The client provides programmatic access to LangSmith Deployment. It supports both remote servers and

Get the state of a thread. Args: thread_id: The ID of the thread to get the state of. checkpoint: The checkpoint to g

Get a synchronous LangGraphClient instance. Args: url: The URL of the LangGraph API. api_key: API key for authentication. Can be:

Get a checkpoint tuple from the database. This method retrieves a checkpoint tuple from the Postgres database based on the provided c

Check if a command string contains disallowed characters or patterns.

Drive the run to completion, then return interrupt payloads. Raises: BaseException: If the run ended with an error.

Lifecycle event with `event="failed"` and an error message.

Put writes for a task, to be read by the next tick.

Run a task with retries.

Set up the checkpoint database asynchronously. This method creates the necessary tables in the SQLite database if they don't already

Set up the checkpoint database asynchronously. This method creates the necessary tables in the Postgres database if they don't alread

Set up the checkpoint database asynchronously. This method creates the necessary tables in the Postgres database if they don't alread

Generate a string representation of the task path.

Return the transformer that contributed `key` to the projection.

Return a new serializer with a merged msgpack allowlist.

Create ai message with an any id field.

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

Backdate a row's expires_at into the past without deleting it (unswept).

Return a fake transport whose open_event_stream always raises.

Wire the sync pull callback. Called by GraphRunStream._wire_request_more.

Store `seed_value` at step 1, then two steps that store nothing. Every step carries a write so the walk has something to collect. Returns `(t