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.

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

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

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.

Add two numbers.

Delete a file or subtree; absent — and the banned store root — do nothing.

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

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 returning the raw `APIResponse` object directly.

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

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:

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

Compose header layers into a single layer: a plain mapping, as `default_headers=` and `extra_headers=` accept, that still carries an `Omit` for ev

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

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

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.

Blocks until the stream has been consumed

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

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

Read and return the binary response content.

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

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;