Map a wire channel name to the public channel name used in interleave tuples.

Map a wire channel name to the public channel name used in interleave tuples.

Check if a function is async. This includes both async def functions and classes with async __call__ methods. Args: func: Function o

Check if a type argument represents an injection annotation. This utility function determines whether a type annotation indicates that an arg

Check if a graph is a Node.js graph based on the file extension.

Check if *method* on *inner_type* differs from the base class default.

Check if an annotation is marked as Required/NotRequired. Returns: - True if required - False if not required - None if n

Return True for a root-namespace lifecycle event marking run end. Matches the wire shape ``{method: "lifecycle", params: {namespace: [], data

Return True for a root-namespace lifecycle event marking run end. Matches the wire shape ``{method: "lifecycle", params: {namespace: [], data

Detect a serialized LangChain `ToolMessage` payload. Example: { "lc": 1, "type": "constructor", "id":

Return True if the in-flight ``CancelledError`` came from the task body. Pregel cancels sibling tasks via ``task.cancel()`` when a peer fails, wh

Load writes for one checkpoint, newest-first by ``(task_id, idx)``. ``walk_channel`` reverses the accumulated flat list before returning; DES

Graph: one node, writes a fresh message into every channel each turn.

Build a minimal EventStreamHandle that closes immediately.

Flat graph with an LLM call for messages projection testing.

Build a TypedDict with one DeltaChannel per entry in `freqs`.

Return the routing key for a message-channel event in `active`. Keys on `message_id` when available so concurrent messages that share the sam

Build the SQL scoping a search to a namespace and its descendants. Matches the namespace exactly or requires the `.` separator before any rem

Mirror the factory list `Pregel.stream_events(version="v3")` registers.

Compute l2 distance between a vector X and a matrix Y. Lazy import numpy for efficiency.

Map test-fixture shorthand to the wire shape `langgraph-api` emits. The server emits the lifecycle status as `data.event` with values `runnin

Resolve the namespace this tool call should emit at, or `None` to skip. Mirrors `StreamMessagesHandler.on_chat_model_start`'s namespace

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

Called by `StreamMux._register` after this transformer is wired in. Default is a no-op. Override to capture a reference to the owning

Fired once per discovered namespace (first observed task event). The triggering `cause` (if any) is available as `self._pending_cause`.

Parse an API version into numeric components. Supports optional prerelease suffixes, e.g. `0.9.0rc1`.

Split a namespace segment into `(graph_name, trigger_call_id)`. Segments are formatted `node_name:task_id` by `prepare_next_tasks`. Returns `

Parse a version string into a tuple of (major, minor).

Return True if host_path is inside a workspace member NOT in the closure. When matched_root is the project root (workspace root), it is a parent

Return the set of interrupt ids that are pending without corresponding resume values.

Return a config pointing at a checkpoint that has at least one ancestor. `get_delta_channel_history` walks the parent chain — calling it on the r

Fixture for pipeline mode testing.

Fixture for pipeline mode testing.

Poll latest revision status until terminal status or timeout.

Fixture for pool mode testing.

Fixture for pool mode testing.

Total bytes across checkpoints / checkpoint_blobs / checkpoint_writes rows for this `thread_id`. Uses `pg_column_size` for an in-row payload e

Internal v3 sync streaming implementation. Public entry: stream_events(version='v3'). Extra keyword arguments are forwarded to the underlying

Print final deployment status and raise on failure.

Prepare input for a PULL task, based on the process's channels and triggers.

Route a descendant event into the appropriate channel inbox. Also fans out to any registered descendant handles whose path is a prefi

Stage stub + accumulated delta writes so final_checkpoint's put waits on them (visibility invariant: both must be durable before final

Attempt to reopen the shared stream after a post-ready transport drop. Returns: `True` if a new stream was opened (caller should

Sleep with exponential backoff and jitter for reconnect attempt `attempt`.

Sleep with exponential backoff + jitter before a reconnect attempt.