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-

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

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

Synchronous client for the first-party Anthropic API served through Google's gateway (Claude Platform on Google Cloud). The whole first-party

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

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

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

Asynchronous client for the first-party Anthropic API served through Google's gateway (Claude Platform on Google Cloud). See ``AnthropicGoogleClou

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

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

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

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

The memory stores attached to one session, materialised on disk. :meth:`download` opens a :class:`~._file_store.LocalFileStore` at each attac

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

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

Duck-typed stand-in for a `google.auth` Credentials object.

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

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

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

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

Regular text content.

A refused operation — input the store will not act on. OS errors propagate as ``OSError``.

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

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.

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

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

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

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

This worker's view of one work-item lease: whether it has ended, and why. Shared by :func:`_heartbeat_loop` and the code serving the item. The fi

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

An :class:`AccessTokenProvider` that reads ``ANTHROPIC_AUTH_TOKEN`` at call time.

A memory store could not be materialised on disk. Raised by :meth:`SessionMemoryStores.download`; the worker lets it fail the work item.

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

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

Minimal stand-in for ``AsyncAnthropic`` — only exposes the resource path the runner reads.

A real ``BetaBuiltinFunctionTool``, unlike ``_FakeTool``, so ``run_runnable_tool`` takes its sync-tool branch.

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