Build the optional shared L2 latch store (``None`` = L1-only). Uses the shared ``affinity_store`` semantics; ``"redis"`` imports :class:`Redi

Build (processors, backend) for the classifier routing chain.

Run a request through the processors and the backend in-process. Skips terminal translation on purpose: returning the typed :class:`ChatRespo

Concatenate all ``output_text`` blocks across ``output`` items. The Responses API ``output`` array is heterogeneous — it can contain ``messag

Perform deferred resize work scheduled by ``_on_winch``. Runs from the main loop, never from a signal handler. Steps: * Re-query the

Paint the footer if the child has been quiet long enough. Returns ``True`` iff a paint actually happened. Callable from unit tests as

Validate and normalize a serialized profile type discriminator.

Return ``(help_map, type_map, samples)`` from exposition text. samples keys are ``(metric_name, frozenset(labels.items()))``.

Best-effort live connection count for evidence logging (version-dependent).

Derives the stable identity this router should retain for `request`.

The algorithm label carried by a request context; empty until stamped.

True when the data point carries every wanted `key=value` attribute.

The backend serving `model` over `format` — the default backend when its format matches, otherwise a matching entry in `other_backends`; `None` when t

Hold the banner on screen for up to *timeout* seconds. Returns early if the user presses any key. Only call when stdin is a TTY.

Request/response processor lists for local RL trace logging. Returns ``([], [])`` when ``rl_log_dir`` is ``None`` (logging disabled), or the

Build a single-tier chain for an explicitly selected model.

Execute one request through the branch its headers select.

Run the compatibility chain and translate the final response.

Map an HTTP status code to its outcome bucket. 2xx → ``success``. The codes listed in :data:`RETRYABLE_STATUSES` (429 / 500 / 504) → ``retrya

Closes an open Anthropic thinking block before text/tool content starts.

The coding-agent-launcher default trio. Strong: Claude Opus 4.7. Weak: Kimi K2.6. Classifier: Gemini 3.5 Flash. Profi

Returns a lossy text view of the first assistant output. Only text blocks from the first output are concatenated. Refusals, reasoning, tools, media,

Move launcher diagnostics to a per-run debug log and return its path.

The signal that forces an escalation on the override path.

Decodes OpenAI image block shapes into normalized image sources.

Dispatch one request through the configured app state. Single-chain apps return already-translated Python payloads because ``Switchyard`` sti

Encodes a buffered aggregate into `wire_format`'s JSON body, stamping `served_model` over the encoded id so the caller sees which model answered. Pass

Encodes neutral streaming events into Anthropic Messages events.

Builds a router with escalation enabled (`confirmations=1` latches on the first verdict).

Excludes a target from this request, returning whether it was newly excluded. Re-excluding returns `false`, which is what bounds the overflow retry on

Pull the caller-supplied API key out of an HTTP request's headers. Precedence: the dedicated ``x-switchyard-api-key`` header first, then ``Au

Runs all four checks against a buffered `ChatResponse` and returns the set of failing flags. Streaming responses (where [`ChatResponse::body`] return

Returns the first output item when a response has any output.

Consumes the wrapper and returns the JSON request body.

Returns whether a role name is recognized by a supported provider API.

Detect a context-overflow body using a provider-supplied structured check and substring phrase list. See module docs for the matching strategy.

Loads a TOML deployment file and constructs the complete server state.

Return a :class:`SignalTierSelectorConfig` with this profile's mapping.

Flatten a chat message (or Responses item) to plain text, tool calls included.

Run a callback once after normal stream exhaustion.

Builds a passthrough OpenAI endpoint fixture.

Parses data lines from one SSE frame into JSON, terminal, or empty states.

Returns the cache-eligible fraction for `model` and records the prefix as seen.

Print a session summary to stdout after the launcher exits.