Create a dict of type RequestOptions without keys of NotGiven values.

Interpolate {name} placeholders in `template` from keyword arguments. Args: template: The template string containing {name} placeholders.

The file's bytes; ``None`` when absent.

Wrapper over `transform()` that allows `None` to be passed. See `transform()` for more details.

Archive a Dream Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Sen

Drive one reconcile pass without clock bookkeeping. The public cadence path (``sync_if_due`` plus the clock) is exercised by the worker tests

Test helper: lay out ``configs/<profile>.json`` and optionally ``credentials/<profile>.json`` under ``config_dir``. Accepts either the new ne

Wrapper over `async_transform()` that allows `None` to be passed. See `async_transform()` for more details.

Convert a fixture file into a stream of bytes for testing.

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

Run Deployment Now Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers:

Higher order function that takes one of our bound API methods and wraps it to support streaming and returning the raw `APIResponse` object directl

Higher order function that takes one of our bound API methods and wraps it to support streaming and returning the raw `APIResponse` object directl

Cancel a Dream Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send

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

Download File Args: file_id: ID of the File. extra_headers: Send extra headers extra_query: Add addi

Merge header mappings, with later mappings taking precedence on a key clash, exactly like `_merge_mappings`. The exception is the headers in

Resolve ``root``; creates nothing — only :meth:`create_root` makes the folder.

Convert a synchronous iterator to an asynchronous one.

Transforms a JSON schema to ensure it conforms to the API's expectations. Args: json_schema (Dict[str, Any]): The original JSON sche

Resolve a :class:`CredentialResult` from the environment per the credential-resolution spec. First match wins. Implements steps 2-5 of the sp

Return a valid bearer token, refreshing if necessary.

Loose coercion to the expected type with construction of nested values. If the given value does not match the expected type then it is returned a

Copy only the containers along the given paths. Used to guard against mutation by extract_files without copying the entire structure. Only di

Get a snapshot of directory contents with relative paths.

Upload File Args: file: The file to upload expires_in_seconds: Seconds from upload until the file expires and i

Count the number of tokens in a Message. The Token Count API can be used to count the number of tokens in a Message, includi

Download every attached store's memories to disk. ``session`` arrives already fetched — one snapshot shared with the skills download.

Recursively extract files from the given dictionary based on specified paths. A path may look like this ['foo', 'files', '<array>', 'data'].

Create a Dream Args: model: Model identifier and configuration applied to every pipeline stage. output_behavior

An ``AsyncAnthropic``-shaped client with one memory store named ``notes``. The store lands at ``{workdir}/memory/notes``. Returns the client to

Iterate work items claimed from a self-hosted environment. Each yielded :class:`BetaSelfHostedWork` has already been ack'd. The ``work`` reso

Convert a single MCP content block to an Anthropic content block. Handles text, image, and embedded resource content types. Raises :class:`Un

Usage docs: https://docs.pydantic.dev/2.4/concepts/serialization/#modelmodel_dump Generate a dictionary representation of the model, opti

Get File Metadata Args: file_id: ID of the File. extra_headers: Send extra headers extra_query: Add

An ``EnvironmentWorker`` pointed at a fake client; one work item queued.

Determine whether to use SigV4 auth. Returns True for SigV4, False for API key. Auth precedence: 1. api_key constructor arg → API key mode

Intercept the shared bearer-auth client factory. Returns the list of args the factory was called with so a test can assert on the helper-tele

Blocks until the stream has been consumed

Return a copy of ``client`` authenticated with ``auth_token`` as Bearer. The returned sub-client inherits the parent's full configuration via

Extract a skill download (a zip or tar.* archive) from disk into ``dest``. Skill bundles are wrapped in a single directory named after the skill;

A ``SessionMemoryStores`` with one store already downloaded to disk.

The user's allow/deny verdict for an ask-gated (``always_ask``) tool call.

Add two numbers.