Top Level call

Extract all injected arguments from tool in a single pass. This function analyzes both the tool's input schema and function signature to iden

Build queries to fetch (and optionally refresh the TTL of) multiple keys per namespace. Returns a list of PreparedGetQuery objects,

Build queries to fetch (and optionally refresh the TTL of) multiple keys per namespace. Each returned element is a tuple of:

Combine api_key and custom user-provided headers.

Extract run metadata from the response headers.

Return a tuple of the final list of stream modes sent to the remote graph and a boolean flag indicating if stream mode 'updates' was p

Return the shared fetch task, creating it on first call. A cancelled task is intentionally NOT respawned: subsequent awaiters receive

Get tracer-only metadata defaults from configurable values.

Fold one stage-1 page into the running walk-state mappings. Returns the oldest checkpoint_id seen on this page (smallest, since pages

Inject graph state, store, and runtime into tool call arguments. This is an internal method that enables tools to access graph context that

Whether `path` lives inside a built-in excluded directory.

Return True the first time a subgraph namespace is seen. The task-id suffix is stripped so that the same logical subgraph (e.g. ``"su

Check if a type is Optional.

Return True if an lc=2 id refers to a type in SAFE_MSGPACK_TYPES. Safe types bypass the ``allowed_json_modules`` gate so that old "json" format

Convert a database row into a CheckpointTuple object. Args: value: A row from the database containing checkpoint data.

Convert a database row into a CheckpointTuple object. Args: value: A row from the database containing checkpoint data.

Build a mini-mux with the same factories scoped to `scope`. Used by `SubgraphTransformer` to attach a fresh transformer pipeline to e

Graph where a node emits custom stream events via StreamWriter.

Build a synthetic EventStreamHandle for reconnect tests. Returns the handle and the underlying queue so callers can inject events or the end

Outer graph with a MessagesState subgraph that returns an AIMessage. Uses the whole-message fallback path (node returns AIMessage directly) t

Create a ChatModelStream (sync) or AsyncChatModelStream (async). Wires whichever pump is bound. Prefers the async pump so nested iter

outer → middle → inner. Three Pregel instances, two nesting levels.

Build outer → middle → inner. Three Pregel instances, two nesting levels.

outer → one → two, where both nodes are compiled subgraphs.

Merge metadata without mutating inputs. Top-level keys merge with newer values winning. `lc_versions` is the only mapping-valued key that mer

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

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

**Experimental.** Batch reducer for use with `DeltaChannel`. Processes all writes in one pass — dedup by ID, `RemoveMessage` tombstoning — wi

Build a regex matching the dot-joined prefix on whole namespace segments. Needed because neither LIKE nor GLOB can express "any character except

Build a POSIX regex matching the dot-joined prefix on whole segments. Needed because `LIKE` cannot express "any character except the separator".

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

True if `spec` is a `DeltaChannel` and no value is stored at this checkpoint, requiring an ancestor walk to reconstruct. `_DeltaSnapshot` blo

Validate and normalize a tool's raw return value.

Return True if two reducer operators should be considered equal. Lambdas all share the name '<lambda>' so identity comparison is unreliable;

Cancel remaining tasks if any failed, re-raise exception if panic is True.

Parse a Node.js version string into a major version number.

Return and remove tracked children closed by this task result.

Build per-SearchOp SQL queries (with optional TTL refresh flag) plus embedding requests. Returns: - queries: list of (SQL, pa

Build per-SearchOp SQL queries (with optional TTL refresh) plus embedding requests. Returns: - queries: list of (SQL, param_l

Ensure the shared SSE covers `candidate_filter`. Rotate if not. Open-new-before-close-old: any events buffered server-side between th

Attempt to reopen the shared stream after a transport drop. Returns True if a new stream was successfully opened, False if all reconn

Record this namespace's `lc_agent_name` (first task event wins). Runs for every task-start event, including `ns == self.scope` and tr

Harvest a task's triggering tool_call_id keyed by its task id. A tool-dispatch task seeds `task_id -> tool_call_id`; the spawned subg

Register a newly-discovered grandchild so future events are fanned out. Also drains any events already buffered in this handle's inboxes whos