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

Concatenated text of the posted-back result's text blocks.

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

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

Generate a MessageParam by calling tool functions with any tool use blocks from the last message. Note the tool call response is cached, repe

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

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

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

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"]`.

Render an exception raised by a tool as tool-result content. A :class:`ToolError` carries its own structured content; anything else is render

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

A CUSTOM (user-defined) tool call — the agent emits ``agent.custom_tool_use`` rather than ``agent.tool_use`` for these.

Open the wire for this hop: its message_start (raw for stream A; suppressed or id-rewritten for a spliced hop), the queued seam frames,

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

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

Take a blocking function and create an async one that receives the same positional and keyword arguments. Usage: ```python def

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.

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.

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

Map a filesystem ``OSError`` to a consistent, runtime-independent message. The raw ``OSError`` string is platform-specific (``[Errno 2] ENOENT: .

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 first non-None value from the given env vars, or None.

Fall back to ``env_var`` for ``value``; raise a clear error if still empty. The ``ANTHROPIC_*`` env vars are the ones the ``ant worker poll --on-

Return ``name`` as a confined relative path, or raise on path-traversal. Strips ``.`` components; rejects absolute paths and any ``..`` component

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

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

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

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

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.

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

Get the helper name from an object, if any.

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

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

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

Write a file, creating parent directories as needed.