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.

Fetch and write the given memories, :data:`_FETCH_CONCURRENCY` at a time. The sync's content pass: the listing carried no content, so each

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

Rebuild a destroyed folder from the server; sends no deletes, no uploads.

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

Remove the file for a memory the server no longer has, if it still holds ``expect_sha``. Returns ``None`` when the file is gone from disk, ``

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-

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 server's view of the lease carried by a 412 heartbeat response, or empty if absent.

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

Where one store's files land on disk. The store's files land at its ``mount_path`` — the very location the agent's system prompt tell

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 headers a request is about to be sent with. `omitted` holds the (lowercase) names a header layer explicitly removed with `Omit`.

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.

Close the response body stream. This is called automatically if you consume the entire stream.

content_block_stop events for any blocks still open.