Finishes target-provider stream emission after the source stream closes.

Serialize a Chat Completions chunk stream to OpenAI-style SSE frames. Accepts any async iterator of objects with ``model_dump()`` (OpenAI SDK

Return an :class:`LLMClassifierConfig` with this profile's prompt baked in. ``disable_reasoning=None`` (default) auto-detects from ``model``

Captures the current monotonic clock instant.

Extracts the tool-result signal and stores it on the request context.

Copies unknown provider fields into the IR extension map.

Record one failed ``switchyard_upstream_attempts_total`` when attributable. Counts an attempt only for failures attributable to the upstream call

Render a stats snapshot as Prometheus text-format exposition. Args: snapshot: The dict returned by :meth:`StatsAccumulator.snapshot_sync`

Normalize response-format tags and wire strings.

Drives a shared router through one turn in the default test session.

Parse an SSE frame string into its JSON ``data:`` payload(s). Follows the SSE contract: a frame's ``data:`` lines are joined with newlines to

Tiers named the way a deployment would name them.

Translate an async stream between provider event formats. Closes *stream* on every exit path. When the client disconnects, the ASGI s

Sets the stable, low-cardinality telemetry name for this composition.

Best-effort close of an upstream response stream. On every exit path — normal completion, mid-stream error, or the client disconnecting (whic

Build the deterministic profile and return its dispatch backend.

Resolve the selected deployment, defaulting to the packaged OpenRouter config.

A context shaped like one a router leaves behind for the terminal role.

Drop ``output_config.format`` from an inbound Anthropic body in place. Claude Code 2.1.1x sends ``output_config.format`` (a structured-output

Builds a random router whose targets all share an echo client.

Appends `note` to the request as conversation text. It joins the trailing user message when there is one, rather than opening a turn of its own: Anth

Attach request metadata and redacted headers to the Python context.

Drains JSON stream events and rejects unexpected text frames.

Translate :class:`SwitchyardContextPoolExhaustedError` into a 400. Raised by the chain executor when every routing target has been evicted af

Decodes a byte stream of `source`-format SSE frames into neutral IR chunks. Operates on raw bytes, not any HTTP client type: the caller adapts its tr

Builds the policy used by exact wire round-trip tests.

Encodes one neutral or preserved stream event for a target provider. A preserved event replays its retained JSON value unchanged when its source and

Emits the initial Responses created event once per stream.

Create a profile config from the validated parsing model.

Return headers to attach to outbound LLM SDK clients. Returns an empty dict when telemetry is opted out, so callers can pass or merge the res

Serializes JSON values into provider argument strings.

Whether ``model`` tolerates the vLLM ``enable_thinking=False`` hint. ``False`` for Anthropic/Bedrock/Claude ids (they 400 on it), else ``True``

OpenClaw personal-assistant traffic; SIMPLE+MEDIUM→weak. Casual chitchat, lookups, light memory recall route to the weak tier; tool o

Stamp the tier for this turn and maybe escalate. Leaves the request unchanged.

A one-user-turn request, the thing a note gets spliced into.

Normalize a request-format tag to the Python enum.

Execute the complete Profile protocol lifecycle with a derived context.

Extracts text-like blocks and joins them for text-only provider fields.

Return a plain dictionary representation.

Extracts usage from a buffered response body.

Probe ``GET /health`` until HTTP 200 or timeout.

Sets the target used when no router selected a target.

Build the optional LLM fallback classifier for stage_router routing.

Render the footer as a single escape-sequence blob (no I/O). Order matters: * ``DECSC`` first — saves the child's cursor + SGR attrs

An OpenAI Chat Completion JSON body whose content is the classifier output.

Drain a Responses API stream and summarize events. Returns ``(event_types, text, function_calls)``: * ``event_types`` — the ``type`` field o

Aggregate deltas from an OpenAI SDK ``ChatCompletionChunk`` stream. Reassembles fragmented fields across chunks using the OpenAI streaming co

An OpenAI Chat Completion JSON body (non-streaming).

Drain ``master_fd`` non-blocking and write the batch to stdout. Returns ``False`` if the child closed (EIO or EOF), else ``True``. T