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 nested `

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.

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

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.

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

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.

Return a valid bearer token, refreshing if necessary.

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

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

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

Convert a synchronous iterator to an asynchronous one.

Compact the conversation before the model's next turn. This only schedules the compaction. Once the current turn has finished, including

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

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 `CredentialResult` from the environment per the credential-resolution spec. First match wins. Implements steps 2-5 of the spec prec

Upload File Args: file: The file to upload. Only the final path component of the part's `filename` is kept;

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.

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

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

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

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

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

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

Clear the cached token so the next `get_token` re-invokes the provider. Also sets a one-shot `force_refresh` flag so on-disk providers skip

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

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

Read and return the binary response content.