Workdir with two symlink cycles, a link that escapes, and a link whose target spells its way through a cycle to the escaping link.

Validate and resolve memory paths

Add one or more messages to the conversation history. This invalidates the cached tool response, i.e. if tools were already called, then they

Create a new client instance re-using the same options given to the current client with optional overriding.

Given a type like `APIResponse[T]`, returns the generic type variable `T`. This also handles the case where a concrete subclass is given, e.g.

Clear the cached token so the next :meth:`get_token` re-invokes the provider. Also sets a one-shot ``force_refresh`` flag so on-disk provider

Convert MCP resource contents to an Anthropic content block. Finds the first resource with a supported MIME type from the result's ``contents

The request-body form of a redeemed credit token — the object shape, best-effort mode.

Poll the environment and service each claimed session until cancelled. Loops forever; cancel the task (or wrap it in :func:`asyncio.wait_for`

Track a content_block_stop, shifting `event["index"]`.

A new client with the given middleware appended after this client's middleware. Convenience for applying extra middleware to a single request

Pull a single item from a sync iterator; assert there was one.

Return an ``httpx.Client``, lazily creating (and tracking) one we own.

True only for the base ``Anthropic`` / ``AsyncAnthropic`` classes, not subclasses. Subclasses (``AnthropicAWS``, ``AnthropicFoundry``) have their

Read and cache the config file, resolving ``base_url`` and ``credentials_path``.

Return the provider a client with ``base_url`` should exchange through. Binds in place, unless another client already bound this instance to

Service a single, already-claimed work item without the poll loop. Builds the per-session :class:`AgentToolContext` (workdir from this

The ``x-stainless-helper: <value>`` header dict, for passing into a ``merge_headers`` call or as ``extra_headers``/``default_headers``. Typin

A fallback hop that contributes one text block, then refuses with a fresh token.

True for a 4xx that retrying will not fix (bad key, missing resource). Aligns with the core client's ``_should_retry`` policy: 408 / 409 / 429 ar

A byte-iterator over the decoded response content. This automatically handles gzip, deflate and brotli encoded responses.

List available models. The Models API response can be used to determine which models are available for use in the API. More

A client with the default (non-strict) response validation. The fixture wire's terminal refusal delta self-reports a `{type: "message"}` iter

Convert an MCP tool to a sync runnable tool for ``tool_runner()``. Example:: from anthropic.lib.tools.mcp import mcp_tool tools

Pretty print an object to a string

Add a pydantic config for the given type. Note: this is a no-op on Pydantic v1.

`entry` applied as a patch against `body`: a field set to a value overrides it, a field explicitly `None` unsets it (absent from the retried r

The traffic seen by ``base_url`` is exactly one exchange followed by one request bearing the token that exchange minted.

Return the first non-None value from the given env vars, or None.

Reject non-``https://`` token-endpoint URLs. Localhost is allowed for testing so ``base_url="http://localhost:8080"`` works against a local `

Create ``path`` and any missing parents with ``mode``, regardless of umask. ``Path.mkdir(parents=True, mode=...)`` and ``os.makedirs(mode=...)``

True if ``child`` is ``root`` or a path inside it (both already resolved).

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

Ensure that the signature of the second function matches the first.

Construct a BaseModel class without validation. This is useful for cases where you need to instantiate a `BaseModel` from an API response as

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.

Create a new client instance re-using the same options given to the current client with optional overriding.

Whether or not the response body has been closed. If this is False then there is response data that has not been read yet. You must e

Return whether the provided argument is an instance of `TypeAliasType`. ```python type Int = int is_type_alias_type(Int) # > True

Convert an MCP prompt message to an Anthropic ``BetaMessageParam``.

Add single quotation marks around the given string. Does *not* do any escaping.

Update the parameters for the next API call. This invalidates any cached tool responses. Args: params (ParsedMessageCrea

Dispatch or resolve a gated call according to the user's verdict. The idle-clock hold accounting lives here: a denial drops the held