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

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

The hop's request body: the refused request's, with the entry's overrides merged over it and extended by the continuation. The server

Returns whether or not the given type is either a `BaseModel` or a union of `BaseModel`

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

TypeGuard for determining whether or not the given type is a subclass of `Stream` / `AsyncStream`

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

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

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

Drop one hold; the last release applies any deferred arm. Once nothing gated is held or in flight, a deferred ``end_turn`` countdown

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

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

Higher order function that takes one of our bound API methods and an `APIResponse` class and wraps the method to support returning the given respo

Higher order function that takes one of our bound API methods and an `APIResponse` class and wraps the method to support streaming and returning t

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.

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``):

Async version of :func:`_force_stop_quietly`.

Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunks

Append `addition` to a comma-separated header value, skipping tokens that are already present so the same helper isn't recorded twice. Values

Apply a content_block_delta to the accumulating block at `index`.

Reduce an archive entry's Unix mode to ``0o755`` if it is executable, ``0o644`` otherwise. Skill bundles can ship executable scripts (e.g. ``

Fill `None` fields on `primary` from `fallback`.

Build a :class:`CredentialResult` for the env-var federation path (step 4 in the precedence spec). Returns ``None`` if the required trio isn't

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the result-event params matching ``ev``'s tool-call kind. A custom tool call (``agent.custom_tool_use``) is answered with a ``user.cust

Call the provider, retrying once on a 401 from the token endpoint.

Interactive-login profile. With a ``client_id`` in the auth block, we run the refresh_token grant on expiry; without one, we treat the

Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise.

Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise.

Remove the skill directories :meth:`setup_skills` downloaded. Only the directories this context created are removed — a pre-existing

Parse a credentials-file ``expires_at`` field into Unix seconds.