`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=...)``

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.

Fold header layers into one `httpx2.Headers`, later layers taking precedence whatever a name's casing. An `Omit` value removes the header set by

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.

One file's sha256; ``None`` when absent. Shares :meth:`hashtree`'s cache.

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

The relative path of every file under the directory ``under``.

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

Rename ``src`` to ``dst``; an existing ``dst`` is refused. The banned store root as either end does nothing.

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

Read a UTF-8 file without newline translation.

Get a specific model. The Models API response can be used to determine information about a specific model or resolve a model

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

Resolve the config directory. ``ANTHROPIC_CONFIG_DIR`` env var → platform default. Platform defaults: * Linux & macOS: ``~/.config/ant

Decide how the runner loop treats a finished assistant turn. - ``run_tools``: run the turn's client tool calls, append their results and continue

If the given type is an `Annotated` type then it is returned, if not `None` is returned. This also unwraps the type when applicable, e.g. `Requir

A session that never completes on its own, with the fake heartbeat held back until the runner is serving it: the heartbeat's outcome — not skill

``json.dumps`` with ``SecretStr`` values unwrapped at dump time. Returns bytes so call sites can pass the result inline (request content, ``o

The store's memories — ``basic`` view (shas, no content) at :data:`_LIST_PAGE_SIZE` per page unless the caller needs ``full`` pages. `

Truncate a token-endpoint error body for safe inclusion in an exception.

Raise :class:`ToolError` when ``target`` falls under a read-only root. Roots resolve at check time, exactly like ``allowed_roots`` in :func:`

base_url precedence: top-level config field → bound (the owning client's base_url, via :meth:`bind_base_url`) → default. Validated aga

Resolve a configured cap to an effective size limit. ``not_given`` selects ``default``; ``None`` disables the size check (uncapped); a positi

Run the worker to completion and return the wall-clock seconds it took.

The synthetic `fallback` content block marking one model boundary.

Detach the frames chained onto ``err`` before raising from it. Foreign frames (json decoder, httpx transport) hold raw payloads — request bod

Transform the given data against the expected type. Args: annotation: The direct type annotation given to the particular piece of data.

Inverse of :func:`_wrap_secret_fields` for a single value; pass-through for values that were never wrapped (absent or non-string fields).

Reject profile names that could escape the config directory. Profile names come from user-controlled sources (``ANTHROPIC_PROFILE``, the ``ac

Wrap the secret fields of a parsed JSON object in ``SecretStr``. Called at every boundary where credential material enters SDK code. Tracebac

(Re)start the idle countdown from now and wake the watchdog. Deferred while any gated call is held or in flight — stopping then would

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

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

Adopt the owning client's ``base_url`` as a fallback for the token exchange. Slots between the config file's own ``base_url`` field and

Close the underlying HTTPX client. The client will *not* be usable after this.