Invoke ``self._provider``, tolerating legacy zero-arg callables.

Whether calling the given object returns a coroutine. Unlike `inspect.iscoroutinefunction(obj)` this also handles class instances that define

True when ``fn`` is a function produced by :func:`contextlib.asynccontextmanager`.

True when ``fn`` is a function produced by :func:`contextlib.contextmanager`. ``contextmanager`` wraps the generator function with ``functools.wr

Pin requests sharing the state to the entry being tried (or warn that there is none).

Transform the given `data` based on the annotations provided in `type_`. Note: this function only looks at `Annotated` types that contain `Proper

Merge two mappings of the same type, removing any values that are instances of `Omit`. In cases with duplicate keys the second mapping takes prec

The non-streaming retry body: the fallback entry merged whole over the original params, plus the refusal's credit token when it minted one.

The raw-response mode the original caller entered the middleware chain with.

Build the options the base middleware handler hands to `_attempt_request()`. Returns a copy so that mutations made by the request pipeline never

Raise a redacted :class:`WorkloadIdentityError` from a non-200 token-endpoint response. Shared between the jwt-bearer exchange path in this modul

Return the stripped contents of ``<config_dir>/active_config``, or ``None`` if the pointer file is missing or empty.

Read the credentials file. Re-reads on every call — daemons rotate it. On Unix, verifies the file is not group/world-readable. World-readable

The policy category that caused the refusal; only the beta surface carries one.

Resolve and validate all Mantle client configuration. Returns (resolved_api_key, resolved_base_url, use_sigv4, merged_headers).

Resolve a configured cap to an effective size limit. ``not_given`` selects ``DEFAULT_MAX_FILE_BYTES``; ``None`` disables the size check (unca

Assert ``candidate`` resolves to a descendant of ``base``, return it verbatim. The containment check uses ``resolve(strict=False)`` on both sides

Convert MCP resource contents to an Anthropic content block.

The content blocks the runner computed and posted back, as carried in ``result`` (the flat ``content`` convenience field was removed).

Drive the session tool loop, yielding an iterator of :class:`DispatchedToolCall`. :meth:`__aiter__` (and the module-level :func:`_run_

A copy of the served hop's response with `seams` prepended to its `content`, or `None` when the body isn't the expected message shape. The ca

Serialize an event back to its SSE wire form (`event: ...\\ndata: ...\\n\\n`). Multi-line `data` is emitted as one `data:` line per line, matchin

Whether an exception raised by a request attempt should be retried. Also returns the HTTP response behind the failure, when there is one, so

A synthetic response standing in for `original`, with `stream` as its body. The spliced frames are emitted post-decode, so the original's con

The chain entry this request starts at (-1 = the original params). Only an explicit `BetaFallbackState` pin moves the start; without one

Drop entries whose value is an `Omit` removal marker.

A copy of `body` with `{type: "fallback"}` seam blocks filtered out of the replayed message history; `body` itself when there are none. An as

Convert a hop's accumulated response blocks to the appended assistant turn. A `fallback_has_prefill_claim` refusal guarantees the partial output

Return the runtime classes in an `Annotated[Union[...], ...]` type alias.

``User-Agent`` value sent on token-endpoint POSTs. Computed lazily so this module doesn't need to import ``_version`` at module load time (th

Return as soon as any of ``events`` is set.

Warn when an ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` from the environment is set alongside signals that would normally drive profile /

Warn when an explicit ``api_key=`` / ``auth_token=`` argument shadows an explicit ``credentials=`` provider. Call *after* any copy-inheritance

Emit a log warning at most once per ``key`` per process.

A copy of `request` with `betas` appended to its `anthropic-beta` header (skipping values already present) and the middleware's helper-telemetry t

Fold a refused hop's outcome in, readying the next hop.

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

Run a runnable tool's optional cleanup. Drives the legacy ``aclose`` / ``close`` attribute (awaited if it returns an awaitable) and, when the

(Re)start the idle countdown from now and wake the watchdog.

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

The chain state after stream A's chainable refusal.

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

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

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

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.

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

Perform a single RFC 7523 ``jwt-bearer`` exchange and return the resulting :class:`AccessToken`. This is a one-shot convenience wrapper aroun

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.