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

Apply a comparison operator, matching PostgreSQL's JSONB behavior.

Internal v3 async streaming implementation. Public entry: astream_events(version='v3'). Extra keyword arguments are forwarded to the underlyi

Force projection channels to accept pushes (skip lazy-subscribe gate). `StreamChannel.push` only appends to the local buffer when a subscribe

Arm `mux` and every mini-mux currently held by SubgraphTransformer handles. Mini-muxes are created during `mux.push(...)` when a new direct c

Execute single tool call asynchronously with awrap_tool_call wrapper if configured. Args: call: Tool call dict. input

Fixture for regular connection mode testing.

Fixture for regular connection mode testing.

Process batch GET operations. Args: get_ops: Sequence of GET operations. results: List to store results in.

Process batch LIST NAMESPACES operations. Args: list_ops: Sequence of LIST NAMESPACES operations. results: List to st

Process batch PUT operations. Args: put_ops: Sequence of PUT operations. cur: Database cursor.

Process batch SEARCH operations. Args: search_ops: Sequence of SEARCH operations. results: List to store results in.

Bind the deltas log to sync or async iteration. Called by `ToolCallTransformer` when constructing this handle so the log matches the

Bind and optionally wire StreamChannel instances in a projection. All StreamChannels are bound and tracked. Channels with a name are

Summarize which ignored directories must still be traversed. Most negations only require walking a small, concrete chain of parent directorie

Calculate the relative path from build context to langgraph.json directory.

Return `True` if we can try the REST state before waiting on the lifecycle. True only when the caller passed an explicit `thread_id` (not a m

Return `True` if we can try the REST state before waiting on the lifecycle.

Wait for the run id, briefly let events flow, then cancel.

Chain two futures so that when one completes, so does the other. The result (or exception) of source will be copied to destination. If destin

Check if type is allowed. Returns True if allowed, False if blocked.

Check if a method invocation is allowed.

Presents a list of templates to the user and prompts them to select one. Returns: str: The URL of the selected template.

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

Coerce `values` dicts inside checkpoint or debug payloads in-place. Skips the initial checkpoint (where next contains ``__start__``) because

Compare values in a JSONB-like way, handling nested objects.

Consume an async iterator.

Build a `Cookie` header for the WebSocket handshake. Why pass `path`: `dict(client.cookies)` flattens the entire jar without domain/path filt

Build a `Cookie` header for the WebSocket handshake. Why pass `path`: `dict(client.cookies)` flattens the entire jar without domain/path filt

Internal helper to copy state from another Future. The other Future may be a concurrent.futures.Future.

Compute cosine similarity between a vector X and a matrix Y. Lazy import numpy for efficiency.

Compute cosine similarity between a vector X and a matrix Y. Lazy import numpy for efficiency.

Compute cosine similarity between a vector X and a matrix Y. Lazy import numpy for efficiency.

Create a deployment and return its ID and next step number.

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