List checkpoints from the in-memory storage. This method retrieves a list of checkpoint tuples from the in-memory storage based on th

Whether `event` should be delivered for `definition`.

Return the approximate size of the queue (not reliable!).

Set the cached values for the given keys and TTLs.

Set the per-attempt timeout policy for this node.

Tokenize a path into components. !!! info "Types handled" - Simple paths: "field1.field2" - Array indexing: "[0]", "[*]", "[-1]"

Create a database cursor as a context manager. Args: pipeline: whether to use pipeline for the DB operations inside the context m

Create a database cursor as a context manager. Args: pipeline: whether to use pipeline for the DB operations inside the context m

Build a DeltaChannel with an explicit type via the Annotated injection path.

Record that an inbox has an active consumer. If the handle is already closed (status != 'started'), immediately enqueue a sentinel so

Migrate a saved checkpoint to new channel layout.

Create n checkpoints on tid (optionally across namespaces). Returns stored configs.

Build a `tasks` ProtocolEvent carrying a TaskResultPayload (finish).

Remove a subscription from the registry. No-op if already absent.

Execute multiple operations asynchronously in a single batch. Args: ops: An iterable of operations to execute. Returns:

Add a sequence of nodes that will be executed in the provided order. Args: nodes: A sequence of `StateNode` (callables that accep

Asynchronously delete an item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the nam

Asynchronously delete all checkpoints and writes for the given run IDs. Args: run_ids: The run IDs whose checkpoints should be de

List and filter namespaces in the store asynchronously. Used to explore the organization of data, find specific collections, or navig

Wire the sync pull callback onto every projection in this mux. Records the pump on the mux so child mini-muxes built by `_make_child`

Tear down the controller, awaiting any pending rotation closes.

Coerce a runnable-like object into a Runnable. Args: thing: A runnable-like object. Returns: A Runnable.

Context manager that creates a .tar.gz archive of the project source. Uses _assemble_local_deps to discover local dependencies referenced in

Create an `EncryptedSerializer` using AES encryption.

Retrieve a single item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the namespace.

Override: walk the parent chain ONCE for all requested channels. Each channel terminates independently at the nearest ancestor whose

Map a protocol event's `method` to its subscription channel. Returns `None` for unrecognized methods so new server-side channels (e.g. from e

Drive the run to completion, then return whether it was interrupted. Raises: BaseException: If the run ended with an erro

Whether `event_namespace` starts with `prefix`. Segments compare literally first; if the prefix segment contains no `:`, the candidate is als

List checkpoints from the database. This method retrieves a list of checkpoint tuples from the SQLite database based on the provided

Replace the request with a new request with the given overrides. Returns a new `ToolCallRequest` instance with the specified attributes repla

Return a new execution info object with selected fields replaced.

Set the child Runnable config + tracing context. Args: config: The config to set.

Summarize checkpoint history into a readable format for assertions. Returns a list of dicts (newest-first, matching get_state_history order) with

Summarize checkpoint history into a readable format for assertions. Returns a list of dicts (newest-first, matching get_state_history order) with

Ensure the background processing loop is running.

Mark a handle terminal once. Returns True on first transition.

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

Raise NotImplementedError for kwargs unsupported by the v3 streaming path.

Return the .env file path implied by the config, or None for inline dicts.

Convert a timezone argument to an IANA timezone string. Accepts: - A string (returned as-is, assumed to be an IANA timezone name)

Strip push stamps from a StreamChannel's internal buffer.

Delete all checkpoints and writes associated with a thread ID. Args: thread_id: The thread ID to delete. Returns:

Get a checkpoint tuple from the database asynchronously. This method retrieves a checkpoint tuple from the Postgres database based on the

Execute a batch of operations. Args: ops (Iterable[Op]): List of operations to execute Returns: list[Result]

Apply updates to the graph state in bulk. Requires a checkpointer to be set. Args: config: The config to apply the updates to.