Put the item on the queue. The optional 'block' and 'timeout' arguments are ignored, as this method never blocks. They are provided

Send a request that automatically reconnects to Location header.

Send a request that automatically reconnects to Location header.

Get a list of cron jobs. Args: assistant_id: The assistant ID or graph name to search for. thread_id: the thread ID t

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

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

Stop the TTL sweeper thread if it's running. Args: timeout: Maximum time to wait for the thread to stop, in seconds.

Stream results using SSE.

Stream the results of a request using SSE.

Apply writes / subgraph states to tasks to be returned in a StateSnapshot.

Trigger a remote build revision with the uploaded tarball.

Return a shallow clone with a derived msgpack allowlist.

Initialize the run stream. Args: graph_iter: Pull-based iterator over the graph's stream, or `None` for nested ru

Update `interrupted` / `interrupts` / `_run_done` from a lifecycle or input event.

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

Assembles the writes into a list of tuples.

Perform batch similarity search for multiple queries.

Demux stage 2 rows per channel; produce per-channel histories. stage2_rows carry `channel` on every row. We build per-channel `writes

Build stage 1 SQL with K parallel version lookups + seed probes. For channels=["messages", "files"] (with `paged=True`) the result is::

Build stage 2 SQL as a per-channel UNION ALL. For each channel with a non-empty chain, emit one branch reading `checkpoint_writes` for that s

Four-checkpoint chain spanning the migration boundary: * `cp0` — pre-delta ancestor OLDER than the seed. Its write (`OLDER-WRITE`)

Build ServerInfo from config configurable. The server puts assistant_id/graph_id in config configurable and the authenticated user dict in co

Like ``_runner`` but exposes the coroutine for arg introspection. Caller must close ``captured["coro"]``.

Close a handle, optionally after a brief delay. Used to detach closing the old stream from the synchronous rotation step so the new stream ca

Coerce context input to the appropriate schema type. If context is a dict and context_schema is a dataclass or pydantic model, we coerce. Els

Normalize the value stored under `CONFIG_KEY_RUNTIME` into a `Runtime`. During a graph run this is always a `Runtime` the framework created and

Return a snapshot of in-flight tasks scheduled via transformers.

Return the union of `required_stream_modes` across registered transformers. Transformers declare the stream modes they need to function, and

Build a config that mimics `CONFIG_KEY_READ` as Pregel installs it. Pregel always installs a `functools.partial(local_read, scratchpad, chann

Create a RunnableConfig with mocked runtime for direct ToolNode testing.

Create a mock Runtime object for testing ToolNode outside of graph context. This helper is needed because ToolNode._func expects a Runtime parame

Create a base class.

Get a cursor for the SQLite database. Args: transaction: Whether to use a transaction for database operations. Yields:

Embed a single text.

Embed a single text.

Embed a single text.

Process and validate index configuration.

Escape GLOB metacharacters so `text` is matched literally. GLOB has no `ESCAPE` clause, so metacharacters are wrapped in a character class in

Escape LIKE metacharacters so `text` is matched literally. Namespace labels may contain `_` and `%`, which would otherwise act as wildcards:

Execute tool call asynchronously with configured error handling. Args: request: Tool execution request. input_type: I

Helper to extract and parse a JSON value from an ENV line in a Dockerfile.

Extract state from input. Three input shapes: - `ToolCallWithContext` dict — legacy Send payload carrying an inlined state

Fetch the current thread state from the REST endpoint.

Fetch the current thread state from the REST endpoint.

Filter validation errors to only include LLM-controlled arguments. When a tool invocation fails validation, only errors for arguments that the LL