Open a typed subscription against the shared SSE. Returns an iterator that yields raw `Event` dicts matching the given filter. Multip

Show warning if image_distro is not set to 'wolfi'. When ``emit`` is provided, each warning line is sent through it (used by callers that nee

Create ai message with an any id field.

Compile a minimal DeltaChannel-backed `messages` graph. `two_nodes=True` adds a second writer node so `bulk_update_state` can route distinct

Run *operation*, prompting for a workspace ID on org-scoped 403s. On success the original *client* is returned as-is. If the user is prompte

Return a mock Cron object response.

Asynchronously get the cached values for the given keys.

Dispatch an event on the async lane. Awaits each transformer's `aprocess` in registration order before appending to the main log. A s

Create a docker compose file as a string.

Aggregate a set of subscription filters into one covering filter. Direct port of `client/stream/index.ts:#computeUnionFilter`. - Channels ar

Create a checkpoint for the given channels.

Create a new PostgresStore instance from a connection string. Args: conn_string: The Postgres connection info string.

Access LangGraph [`StreamWriter`][langgraph.types.StreamWriter] from inside a graph node or entrypoint task at runtime. Can be called from inside

Sanitize a deployment/directory name into a valid deployment name. LangSmith Deployment names only allow lowercase alphanumeric characters an

Send a `PUT` request.

Apply ancestor writes oldest-to-newest via a single reducer call. If any write is an Overwrite, the last one in the sequence acts as

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

Sets a conditional entry point in the graph. Args: path: The callable that determines the next node or nodes. If

Set up the store database. This method creates the necessary tables in the Postgres database if they don't already exist and runs dat

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

Write dict to disk

r"""UUID version 6 is a field-compatible version of UUIDv1, reordered for improved DB locality. It is expected that UUIDv6 will primarily be u

Create a copy of the Pregel object with an updated config.

Produce a valid protocol event lifecycle: start, delta, finish.

Populate saver with test data for list tests. Returns lookup info.

Finalize on the async lane. Awaits every task started via `StreamTransformer.schedule()` across all transformers, then calls `afinali

Asynchronously store or update an item in the store. Args: namespace: Hierarchical path for the item, represented as a tuple of s

Normalize a timeout value to positive-second policy fields.

Create an AsyncSqliteStore with vector search capabilities.

Produce "task" events for stream_mode=debug.

Remove task IDs from checkpoint namespace. Args: ns: The checkpoint namespace with task IDs. Returns: str: The checkpoint na

Delete expired store items based on TTL. Returns: int: The number of deleted items.

Return a mock cron response payload.

Resolve env vars from langgraph.json 'env' field or a .env fallback.

Return ``{registry}/{repo}@sha256:<hex>`` for a freshly-pushed image. Reads ``RepoDigests`` via ``docker image inspect`` — the local daemon r

Check if the given exception should be retried based on the retry policy.

Convert an SSE event+data pair into a v2 stream part dict. Returns None for ``end`` events (signals end of stream).

Strip symlinks, hardlinks, and traversal paths from archive.

Remove the task from the tasks dict when it's done.

echo.

POST a command. Returns the response JSON, or `None` for 202/204. Raises: httpx.HTTPStatusError: server returned >= 400.

Stream events from this remote graph. For `version="v3"`, returns a `_RemoteGraphRunStream` whose surface matches the local `GraphRun

Create a human message with an any id field.

Create a tool message with an any id field.

Assert a v2 stream part has the required keys and types.

Create a RunnableConfig with mock Runtime for testing ToolNode.

Inspects the given value and returns (is_overwrite, overwrite_value). Recognises three forms: * The typed `Overwrite` dataclass instance.

Create an EncryptedSerializer with AES encryption for testing.

Merge two callbacks values (None / list / BaseCallbackManager). Six cases total (3 base types x 2 non-None new types).

Allocate a subscription id and add it to the registry.

Strip push stamps from a StreamChannel's internal buffer.

Asynchronously copy all checkpoints and writes from one thread to another. Args: source_thread_id: The thread ID to copy from.

Apply writes from a set of tasks (usually the tasks from a Pregel step) to the checkpoint and channels, and return managed values writes to be app

Asynchronously prune checkpoints for the given threads. Args: thread_ids: The thread IDs to prune. strategy: The prun

Mark the channel as errored. Args: err: The exception to surface to the subscriber.

Initialize from a stored blob. Blob types: * `MISSING`: start empty; caller replays writes. * `_DeltaSnapshot(value)`: re

Return the module and name of an object.