Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise.

Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise.

Remove the skill directories :meth:`setup_skills` downloaded. Only the directories this context created are removed — a pre-existing

Create JSON schema from function signature using pydantic.

Path to ``<config_dir>/credentials/<profile>.json`` (secret, 0600).

The environment for the bash subprocess, with the runner's own credentials scrubbed. The bash tool runs model-issued commands, so it must nev

Stream the skill archive to a temp file, then extract it into ``dest``.

Fill empty profile fields from corresponding ANTHROPIC_* env vars. The profile file is authoritative — this only fills fields the file left u

Convert the `APIResponse` returned by the middleware chain into the value the original caller expects. The middleware chain operates on `APIR

Convert the `AsyncAPIResponse` returned by the middleware chain into the value the original caller expects. The middleware chain operates on

Best-effort ``work.stop(force=True)`` for an item that can't be processed. A 409 just means the work already stopped; anything else is logged but

Extract description from parsed docstring.

Tighter auto-discover check for the tier-1 credential chain. Returns ``True`` only if the *active* profile's config file exists. The previous

True if the environment / filesystem contains signals that would normally drive the tier-1 (profile) or tier-2 (env federation) paths of :func

Keep the work-item lease alive while a session is being served. ``work`` must be bound to a sub-client authenticated for the environment; thi

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

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

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

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

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_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

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

Post ``tool_result`` back to the session, retrying transient failures. ``tool_use_id`` is the originating tool-call event id — passed

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

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

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