Metadata class to be used in Annotated types to provide information about a given type. For example: class MyParams(TypedDict): acco

Middleware that retries refused beta `/v1/messages` requests down a fallback chain, reproducing the server-side `fallbacks` wire shape client-

Error that can be raised from a tool to return structured content with ``is_error: True``. When the tool runner catches this error, it will use t

An :class:`AccessTokenProvider` backed by a named profile. A profile is a pair of files under the config directory (``~/.config/anthropic/``

An Anthropic API access token with optional expiry. ``expires_at`` is unix seconds; ``None`` means no expiry information (the token will be t

Exchanges an external OIDC JWT for an Anthropic access token via the RFC 7523 ``jwt-bearer`` grant. This is an :class:`AccessTokenProvider`:

Workdir + path-policy for the agent toolset. Trust model — two tiers: - The file tools (:func:`beta_read_tool`, :func:`beta_write_tool`,

Minimal stand-in for ``BetaSelfHostedWork`` — only fields the poller reads.

Thread-safe cache wrapping an :class:`AccessTokenProvider` with two-tier proactive refresh and single-flight semantics. Refresh policy on eac

Raised when the OIDC token exchange (``POST /v1/oauth/token``) fails.

An :class:`AccessTokenProvider` that always returns a fixed token with no expiry.

Tracks which fallback a sequence of requests is pinned to. Create one and enter it (`with state:` — the same context manager works for both c

Sync resource fake. ``poll_script`` is consumed in order; values are either ``BetaSelfHostedWork``-shaped stubs, ``None`` (no work available),

A view over the request that the client is about to execute. Treat instances as immutable; use `copy()` to derive a modified request.

An :class:`IdentityTokenProvider` that reads a JWT from a file on every call. Kubernetes projected service-account tokens (and similar) are rotat

An :class:`AccessTokenProvider` driven by an in-memory config dict (same shape as ``configs/<profile>.json``) rather than files on disk. Inte

Regular text content.

Run a self-hosted environment worker. Composed from the control-plane poller (``client.beta.environments.work.poller``) and the per-session :

This is a legacy class as it will be replaced by `APIResponse` and `AsyncAPIResponse` in the `_response.py` file in the next major release.

Stores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set.

To explicitly omit something from being sent in a request, use `omit`. ```py # as the default `Content-Type` header is `application/json

Raised when an MCP value cannot be converted to a format supported by the Claude API.

Raised when an API response has a status code of 4xx or 5xx.

Stand-in for the various session event types — only the fields the runner reads are populated.

Records the response wrapper returned by `call_next` and passes it through.

For parameters with a meaningful None value, we need to distinguish between the user explicitly passing None, and the user not passing the pa

A dict subclass that can carry a ``_stainless_helper`` attribute. Behaves identically to a regular dict for serialization and isinstance checks,

Records the `retries_taken` and response status of every attempt the chain runs for.

Bundles an :class:`AccessTokenProvider` with config-level metadata. Returned by :func:`default_credentials`. The ``extra_headers`` dict carri

Attach to a managed-agents session and dispatch its tool calls locally. The sessions-side counterpart to ``client.beta.messages.tool_runner``: an

A fallback hop whose request failed; stamps `recommended_model` when it ends the chain.

Consumes one hop's SSE events, producing the frames to forward to the client while accumulating its content blocks. Events are held until the

A middleware object that is a class instance with an async `__call__` method.

Provides the core interface to iterate over an asynchronous stream response.

File-based memory storage implementation for Claude conversations

Provides the core interface to iterate over a synchronous stream response.

A middleware object that is a class instance with a sync `__call__` method.

Stand-in for the AsyncStream returned by ``events.stream()``. Yields scripted events in order; once exhausted, blocks forever (the real strea

Adapts a :class:`TokenCache` to httpx's :class:`~httpx.Auth` protocol. Used by :meth:`anthropic.Anthropic.custom_auth` to inject ``Authorization: