Close the response and release the connection. Automatically called if the response body is read to completion.

Close the owned ``httpx2.Client`` if we created one.

Close the underlying ``httpx2.Client`` if we created it.

The accumulated content blocks, in start order.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new memory file with the specified content.

Delete File Args: file_id: ID of the File. extra_headers: Send extra headers extra_query: Add additi

Cancel the idle countdown; only signals on an actual transition.

Download the session agent's skills into ``{workdir}/skills/<name>/``. Reads the resolved agent off ``session``, and for each skill fetches its

Execute a memory command and return the result. This method dispatches to the appropriate handler method based on the command type (v

Process one event, returning the frames to forward for it.

The session's last sync — once, at a clean end. Same reconciliation as the cadence syncs, but server deletes skip the waiting window

The outcome once the hop's stream is fully consumed (or cut early).

Frames still owed when the stream ends without a chainable refusal.

Gets the proxy mappings based on environment variables. We use our own logic to parse these variables, as HTTPX doesn’t allow full config

Get the helper name from an object, if any.

Pause the countdown while a gated call is held or in flight.

The hop's request body: the entry applied as a patch against the ORIGINAL request params (never a previous hop's patched body), extended

If the given type is `typing.Iterable[T]`

True for a path usable verbatim as a store location: absolute, no ``..``.

Given an iterator that yields raw binary data, iterate over it & yield every event encountered

Uniform random delay in ``[low, high)`` — spreads out retry storms.

Read and decode the JSON response content.

Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating se

Write ``str`` (UTF-8) or ``bytes`` atomically to the file at ``rel_path``. Missing directories below the root are created; a missing root is

Queue the reached hop's `fallback` seam block at the next monotonic index. Queued seams are flushed by the hop reader once output reaches the

Iterate the raw Server-Sent Events from `response`, before any JSON parsing or event-name filtering. This reads the response body dir

ctor arg → ``ANTHROPIC_IDENTITY_TOKEN_FILE`` → ``None``.

Call ``tool`` with ``input``, awaiting the result if the tool is async. Sync tools run on a worker thread. If the caller cancels (for example on

Update the parameters for the next API call. This invalidates any cached tool responses. Args: params (ParsedMessageCrea

Run one sync when ``sync_interval`` has elapsed since the last. Stores sync in parallel; a store's own paths reconcile in a determini

Degrade to the suppressed refusal when every remaining entry failed over HTTP: replay its message_delta verbatim — `recommended_model`

Return a valid access token, loading ADC / refreshing as needed. Blocking.

Index ``tools`` by their ``name`` for O(1) dispatch lookup. On a duplicate name the later tool wins, matching a plain dict comprehension.

Verifies the webhook signature from the `webhook-id`, `webhook-timestamp` and `webhook-signature` headers using your webhook signing

Strict validation that the given value matches the expected type

Helper method that returns the current proxy, typed as the loaded object

Construct a new synchronous Anthropic client instance. Credentials are resolved in the following order (first match wins): 1. Explic

Construct a new synchronous Claude Platform on Google Cloud client. Auth precedence (first match wins, unless ``skip_auth=True``):