Create a mock Runtime for testing ToolNode directly.

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 mock Runtime object for testing ToolNode outside of graph context.

Simulated user accepts a {"messages": [...]} argument and returns a single message.

Decode a raw WS frame into an Event dict. Returns None and sets `done` if the frame is invalid JSON or not a JSON object.

Dedupe operations while preserving order for results. Args: values: List of operations to dedupe Returns: Tuple of (listen i

Whether a namespace key matches a match condition.

Download a ZIP archive from the given URL and extracts it to the specified path. Args: repo_url: The URL of the repository to download.

Drain a pre-filled inbox of messages events, yielding one stream per message.

Drain a pre-filled inbox of messages events, yielding one stream per message. Mirrors the pre-dispatch pattern in `_SyncMessagesProjection._messa

Drain ``thread.subgraphs`` to a list of {path, messages} dicts. The outer subgraphs iterator must complete before we deep-iterate each handle

Emit the deployment status URL and return it.

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

Fetch terminal thread state, waiting for the lifecycle if needed.

Filter items by namespace and filter function, return items with their embeddings.

Finalize in-flight handles when `interleave_projections` tears down. Mirrors the terminal handling of the dedicated `_ToolCallsProjection` /

Finalize in-flight handles when `interleave_projections` tears down. Mirrors the terminal handling of the dedicated `_SyncToolCallsProjection

Get the API key from the environment. Precedence: 1. explicit string argument 2. LANGGRAPH_API_KEY (if api_key not provided)

Compute the LangSmith dashboard URL for a deployment, if possible.

Return the content of a .dockerignore file. This file is used to exclude files and directories from the Docker build context. It may be over

Helper to generate filter conditions.

Helper to generate filter conditions.

Get a sanitized index type and configuration based on config. Only allow known-safe kinds and integer parameters to avoid SQL injection when

Extract injection instance from a type annotation. Args: type_: The type annotation to check. injection_type: The injection type

Extract the last AIMessage from the input.

Get the vector type operator class based on config.

Compute inner product between a vector X and a matrix Y. Lazy import numpy for efficiency.

Wrap `_dedup_iter` so duplicate event_ids are counted.

Wrap `_dedup_iter` so duplicate event_ids are counted (no asserts here).