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

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

Send the server delete only after the file's absence is confirmed. Records the miss on the first sync; deletes on a later one after t

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

Encode `payload` as one `chunk` event in AWS eventstream binary framing.

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

The causes under an exception group — anyio's wrapper message says nothing.

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

True when the session has at least one memory store attached.

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

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

The 412 the control plane answers a heartbeat with once the item's lease was cleared (re-queued) or is held by another worker.

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