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-

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

Collect deduplicated helper names from tools and messages.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new client re-using the current options, with optional overrides. See ``AnthropicGoogleCloud.copy`` for the override semantics.

Create a new memory file with the specified content.

Delete a memory file or directory.

Delete a memory file or directory.

Apply a content_block_delta to its accumulating block, shifting `event["index"]`.

Download the session agent's skills into ``{workdir}/skills/<name>/``. Reads the resolved agent off ``session``, and for each skill fetches its