Construct a new synchronous Anthropic client instance. Credentials are resolved in the following order (first match wins): 1. Explic

Construct a new synchronous Claude Platform on Google Cloud client. Auth precedence (first match wins, unless ``skip_auth=True``):

Async version of :func:`_force_stop_quietly`.

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

Append `addition` to a comma-separated header value, skipping tokens that are already present so the same helper isn't recorded twice. Values

Apply a content_block_delta to the accumulating block at `index`.

Apply a single ``tool_removal`` / ``tool_addition`` block to ``available``.

Fold one ``tool_removal`` / ``tool_addition`` block into ``available``.

Reduce an archive entry's Unix mode to ``0o755`` if it is executable, ``0o644`` otherwise. Skill bundles can ship executable scripts (e.g. ``

Fill `None` fields on `primary` from `fallback`.

Build a :class:`CredentialResult` for the env-var federation path (step 4 in the precedence spec). Returns ``None`` if the required trio isn't

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the result-event params matching ``ev``'s tool-call kind. A custom tool call (``agent.custom_tool_use``) is answered with a ``user.cust

Call the provider, retrying once on a 401 from the token endpoint.

Interactive-login profile. With a ``client_id`` in the auth block, we run the refresh_token grant on expiry; without one, we treat the

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

Parse a credentials-file ``expires_at`` field into Unix seconds.

Yield the matches whose canonical path is inside ``root``; a match that cannot be canonicalised (symlink loop, unreadable) is dropped, not raised.

Convert MCP ``CallToolResult`` to a value suitable for returning from ``call()``.

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

Feed one hop's SSE events through `reader`, yielding the frames to forward.

Feed one hop's SSE events through `reader`, yielding the frames to forward. The outcome is read from `reader.finish()` afterwards — async generat

Run ``ev``'s tool, post its result, and surface the dispatched call. ``confirmation`` is the verdict that released the call onto the work

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

Replace {name} placeholders in `template`, quoting each value with `quoter`. Placeholder names are looked up in `values`. Raises: Ke

Invoke ``self._provider``, tolerating legacy zero-arg callables.

True when ``fn`` is a function produced by :func:`contextlib.asynccontextmanager`.

True when ``fn`` is a function produced by :func:`contextlib.contextmanager`. ``contextmanager`` wraps the generator function with ``functools.wr