Signal EOF only on channel inboxes that have an active consumer. Inboxes without a consumer would accumulate a leaked None sentinel t

Signal EOF only on channel inboxes that have an active consumer. Inboxes without a consumer would accumulate a leaked None sentinel t

Create msgpack ext hook with allowlist. Args: allowed_modules: Set of (module, name) tuples that are allowed to be deserialized,

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

Call the sync pump until it returns False.

Return env vars copy with deployment-name key removed.

Execute tool call with configured error handling. Args: request: Tool execution request. input_type: Input format.

Single consumer of the shared SSE; routes events to subscriptions. Why: rotation in `_reconcile_stream` replaces `_shared_stream` mid-loop.

Get the underlying model from a RunnableBinding or return the model itself.

Infer exception types handled by a custom error handler function. This function analyzes the type annotations of a custom error handler to determ

Graph that interrupts after the first node.

Create a Redis key from namespace and key.

Build a simple graph with PydanticState for validation error tests.

Return WHERE clause predicates for (a)search() given metadata filter. This method returns a tuple of a string and a tuple of values. The string

Convert namespace tuple to text string.

Track values-event state for output/interrupted/interrupts.

Fired once per tracked namespace when its parent's result arrives, or via finalize/fail safety-net sweeps.

Allocate a subscription id, create a bounded queue, add to registry.

`(config, items)` for every checkpoint with `next == ('__start__',)` — the stable inter-invoke boundaries that round-trip predictably.

Extract top-level field values from a state object (dict, BaseModel, or dataclass).

Map a run exception to a subgraph terminal status and error string.

Strip push stamps from a StreamChannel's internal buffer.

Validate that a filter key is safe for use in SQL queries. Args: key: The filter key to validate Raises: ValueError: If the

Build a messages ProtocolEvent carrying a completed AIMessage.

Async version of `channels_from_checkpoint`. See docstring there.

Fail on the async lane. Cancels every scheduled task across all transformers, awaits them to completion, then runs each transformer's

Asynchronously get the cached values for the given keys.

Asynchronously set the cached values for the given keys and TTLs.

Normalize a timeout value to positive-second policy fields.

Create a cron run. Args: assistant_id: The assistant ID or graph name to use for the cron job. If using graph nam

Build a new Checkpoint from the previous one and live channel state. For each name in `channels_to_snapshot`, a `_DeltaSnapshot(value)` blob

Delete all checkpoints and writes associated with a thread ID. Args: thread_id: The thread ID to delete. Returns:

Return True if the queue is empty, False otherwise (not reliable!).

Ensure that an embedding function conforms to LangChain's Embeddings interface. This function wraps arbitrary embedding functions to make them co

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

Get subset of current_versions that are newer than previous_versions.

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

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

List checkpoints from the database. This method retrieves a list of checkpoint tuples from the Postgres database based on the provide

Whether `event_namespace` matches any of `prefixes` within `depth`.

Strip the dynamic suffix after `:` from a namespace segment.

Top-level banner (pre-step). Text mode does not indent.

Drive the run to completion and return the final state. Methods (not properties) on the async lane so `run.output` without `await` ra

Send a `PATCH` request.

Send a `PATCH` request.

Prepare an immediate node-level error handler task for a failed task.