Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunks

Extract the values of a ``Required[Literal[...]]`` TypedDict field.

Merge two mappings of the same type, removing any values that are instances of `Omit`. In cases with duplicate keys the second mapping takes prec

Adapter: convert a flat legacy config dict into the new nested shape. Many tests in this file predate the schema migration and pass legacy fl

Record an allow/deny verdict and release the held call it gates, if any.

Returns a float of the number of seconds (not milliseconds) to wait after retrying, or None if unspecified. About the Retry-After header: htt

`overrides` applied flat against `base`: a key set to a value overrides it, a key explicitly `None` unsets it, an absent key keeps the base value.

Hook for mutating the given options

Hook for mutating the given options

This method is used as a callback for mutating the `Request` object after it has been constructed. This is useful for cases where you

Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request.

Read an image/PDF as a base64 ``image``/``document`` content block. The text cap does not apply here — its 256 KiB default would reject most

``_read_credentials`` variant that returns ``None`` on absence instead of raising — used by the federation disk-cache path where a mis

Read full history and enqueue every tool-call event still unanswered. Two-pass: read the whole history before emitting so a tool-call whose

The locally runnable tool name a tool-change reference resolves to. Only ``tool_reference`` names a runnable tool; ``mcp_tool_reference`` / `

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-

Resolve ``version`` to the concrete numeric timestamp the ``/v1/skills/{id}/versions/{version}`` endpoints require. ``session.agent.skills[].

Internal: drive a :class:`SessionToolRunner` as an async context manager. Kept as a thin module-level shim because :class:`~anthropic.lib.env

Build the runner's request client. With an environment key, defer to :func:`_copy_client_with_bearer_auth` for a Bearer-only sub-client. With

(code name, locals) for every traceback frame owned by the anthropic package, across the full ``__context__`` / ``__cause__`` chain.

Post ``tool_result`` back to the session, retrying transient failures with jittered exponential backoff until the send retry window elapses.

The serving hop's `fallback_message` completer entry: its own self-reported iteration relabeled, or one built from its delta usage.

Wrap the refusable stream in a response whose body passes events through until a retryable refusal, then splices the fallback chain's events o

Map a Parsed* wrapper to the generated block class it stands in for.

Bridge Messages-API tool-result content to the narrower Sessions-API content union. The two APIs share text/image/document/search_result block sh

Return the runtime classes in an `Annotated[Union[...], ...]` type alias.

Validate the given default headers and custom headers. Does nothing by default.

Return as soon as any of ``events`` is set.

Screen every member name (raising on path traversal, extracted or not), then return the wrapper directory shared by the members that will be e

True for a Unix-host entry recorded as a symlink, device, FIFO or socket. Type bits from other hosts are not a mode, so those entries stay plain f

Ensure that every @overload of overloaded_func contains all params from source_func.

Transform dictionaries based off of type information from the given type, for example: ```py class Params(TypedDict, total=False): ca

Fold mid-conversation ``tool_removal`` / ``tool_addition`` blocks over the locally runnable ``tool_names``. Only ``role: "system"`` messages

Override the base implementation to provide file system clearing.

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.

Close the response and release the connection. Automatically called if the response body is read to completion.

content_block_stop events for any blocks still open.

Collect deduplicated helper names from tools and messages.