Return the runtime classes in an `Annotated[Union[...], ...]` type alias.

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

Return as soon as any of ``events`` is set.

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

Exponential backoff for ``attempt`` (1-indexed), capped at ``cap``.

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.

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>/``. Looks up the session's resolved agent, and for each skill fetches its file

Execute a memory command and return the result. This method dispatches to the appropriate handler method based on the command type (v

Generate a MessageParam by calling tool functions with any tool use blocks from the last message. Note the tool call response is cached, repe

Waits until the stream has been read to completion and returns the accumulated `Message` object.

Waits until the stream has been read to completion and returns the accumulated `Message` object.

Waits until the stream has been read to completion and returns the accumulated `Message` object.

Insert text at a specific line number in a memory file.

Uniform random delay in ``[low, high)`` — spreads out retry storms.

Translates a mapping / sequence recursively in the same fashion as `pydantic` v2's `model_dump(mode="json")`.

Load Application Default Credentials with the ``cloud-platform`` scope and mint an initial access token. Returns the credentials object and t

Load a fixture file from the fixtures directory.

A version of functools.lru_cache that retains the type signature for the wrapped function arguments.

Primary scenario: drive a session yourself and watch each tool call. No work queue and no lease are involved — we create the session, send a