Annotated metadata naming the field that tells the variants of a union apart, e.g. ```py Pet: TypeAlias = Annotated[Union[Cat, Dog], UnionDis

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

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

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

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

Thread-safe cache wrapping an `AccessTokenProvider` or an `AsyncAccessTokenProvider` with two-tier proactive refresh and single-flight semanti

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

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

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

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 the

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

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

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

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

The memory stores attached to one session, materialised on disk. `download` opens a `._file_store.LocalFileStore` at each attached store's di

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

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

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.

Raised when credentials cannot be loaded from local files, config, or the environment.

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

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

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

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.

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.

Stands in for a `@beta_tool` / toolset object: `tools=` takes anything with a `to_dict()`.

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 stream

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 `_heartbeat_loop` and the code serving the item. The first

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 `AccessTokenProvider` that reads `ANTHROPIC_AUTH_TOKEN` at call time.