Return ``reasoning`` / ``reasoning_content`` from a pydantic field. Both names are vendor extensions produced by reasoning models (different

Return a stable display name for role validation errors.

Loop ``os.write`` until every byte is flushed. A single ``os.write`` to a tty can return fewer bytes than requested when the kernel's tty out

Record non-fatal model catalog discovery warnings for ``/v1/models``.

Apply the default tier timeout when a target has no explicit timeout.

Asserts a translated body carries the exact original body in preservation metadata.

Attach the caller-supplied API key to *ctx* when the request carries one.

Build a :class:`RouteTable` from a :class:`RouteBundle`. Single assembly path for both the YAML loader and the launchers. If ``bundle.stats_

Run the wrapped Profile and translate its response for the caller. Raises: SwitchyardProcessorError: A response processor raises

Captures an exact source request body according to preservation policy.

Captures an exact source response body according to preservation policy.

Builds a deterministic strong/weak config for routing tests.

Flatten string-or-content-block message content to text. Handles plain strings, OpenAI/Anthropic text blocks, nested ``tool_result`` content,

Returns mutable access to the leased Rust context.

Collects a decoded IR stream, surfacing the first error instead of panicking.

Decodes a `wire_format` request body into the neutral IR.

Decodes one provider stream event with the built-in codec registry.

Returns an exact preserved request for the target format when available.

Returns an exact preserved response for the target format when available.

Executes the processor/classifier/target-call sequence for wrappers and the trait entrypoint.

Flushes the metric pipeline and returns every exported snapshot.

Extract request metadata from a case-insensitive header mapping.

Create Metadata

General-purpose mixed traffic, conservative SIMPLE→weak mapping. Default-tier on abstain / low-confidence is ``strong`` (fail safer,

The routed request the host should serve. Its [`default_client`](RoutedRequest::default_client) serves the call by default, and its `decision.selected

Look up a target by name; errors if no target has that name.

Translate an unexpected chain failure into the client error envelope. Used when an exception escapes dispatch or response-processing that is not

Latest (max) value for a `switchyard`-scoped metric across snapshots, with `extract` pulling the matching data points' values out of one metric's aggr

Leases the native context carried by a Python `ProxyContext`.

Return non-fatal model catalog warnings in discovery order.

A classifier that hands the capable tier an escalation note, gated to signal-driven escalations.

Claude Opus 4.6 (strong) + Nemotron-3 Super v3 (weak). The flagship strong/weak pair — strong-signal reasoning from Opus for multi-st

Decide a turn's tier from its signal. The rules run in order; the first that fires wins: 1. **Escalate** — a hard reason to go capable (critical err

Builds prefix fingerprints from a request body. Format-agnostic: `system`/`instructions`, then each `messages`/`input` turn.

Builds format-agnostic prefix fingerprints from a request body.

Write proxy/stats/routing details to stderr before the child takes over.

Records one failed classifier or judge call.

Registers or replaces a codec for its declared format.

Returns the registry shared by every server router in this process.

Pick a backend model that supports OpenAI-style tool calling. Some NVIDIA-hosted vLLM deployments (notably the ``nvidia/qwen/qwen3.5-*`` fami

Fulfill the promise with the caller's model-call result. Pass `Err(..)` to propagate a failed model call back to the algorithm. Consumes the promise:

Return whether a response carries a live stream.

Builds an OpenAI Responses target fixture.

Restores the leased context into the Python wrapper.

Routes one turn on a prompt test cascade and returns the recorded model call.

Select a target and return the routing decision dictionary.

Selects a target without mutating a request.

Serves requests until the supplied shutdown future resolves.

Mark *model* as the default entry advertised by ``/v1/models``.

Utility to convert a slice of string pairs into an `http::HeaderMap`.

Return a copy of the current counts; safe to publish.

`target_set`, but the named `overflowing` targets reject every call with a context-window error so the retry path can be driven.

All targets in the set — e.g. for an algorithm to select among.

Keeps the opening task and the last `recent_turn_window` turns after it. A window of `0` keeps the task alone. Inbound decoders normalize client syst

Uses the first user-message text as a fallback key when metadata has no session.

Configures the model that the fake backend records in context.

Overrides the advertised request types.

Configures the route label that the fake backend records in context.

Return the highest-scoring tier; ties resolve to the *stronger* tier. The "ties → stronger" rule is the safer side of the cost/quality trade-

Pin the per-target attribution shape after a successful reroute.