The atomic verdict. ``passed`` is True/False, or None when skipped (e.g. an optional backend isn't installed).

A failure as it crosses the wire — already scrubbed, always actionable.

Executes protocol assignments against the local engine stack.

Owns the queue, the selection pipeline, and the deadline sweeper.

The set of workers currently connected, plus their breakers.

A control plane stub with a real pool, so availability is real logic.

Optional expressive/quality knobs for a longform render (#1208). Every field is ``None``/``False`` by default, and a default instance means *

Enough scheduler to exercise submit / wait / cancel / get.

One contiguous run of text in a single voice, plus trailing silence. ``speed`` (when set) is the per-span rate passed to the engine — Stories'

Snapshot of the host's accelerator capability. Immutable + cached.

Stands in for the scheduler half of `services/gpu_gateway.py`. Same signature and same return contract as the real `run` — a `(waveform, samp

Only the attributes the executor reads — a real pb message needs a ref and a session the executor has no business knowing about.

Thread-safe, process-local store for admin sessions and WS tickets.

Drains the client's outbox, recording each frame's arrival time.

Carries a classified ``WorkerError`` across the execution boundary.

Everything the worker needs to reach and prove itself to a server.

OpenAI-compatible fake. `script(call_kwargs) -> str | Exception` decides each response; every chat.completions.create() call is recorded.

Tunable knobs for the Smart Fit planner. All defaults are deliberately conservative: ≤1.2× audio-only is imperceptible to most listeners; 1.5

Maintains one worker's connection to a control plane.

Implements ``WorkerService`` on top of the scheduler and registry.

Drains the client's outbox, recording each frame's arrival time.

Minimal stand-in for a Playwright sync Page — enough for the judges + the Driver's locate logic to run with no browser.

Time-domain NLMS adaptive filter with Geigel double-talk detection. Operates on narrowband mono PCM at 16 kHz (the rate the dictation path re

Records what UploadResult received, and can be told to refuse.

Stands in for safetensors_rust.SafetensorError — the point being that it is NOT an OSError, which is why the ladder never saw the real one.

A complete evaluation scenario.

Scores case transcripts against a rubric via the configured LLM.

A unit of inference work, independent of which worker runs it.

Counts encodes so cache hits are observable.

Where one job should run, and why.

The resident OmniVoice model in a killable sidecar process.

The endpoint's whole contract with the scheduler: submit, wait, cancel.

Install-step failure carrying user-facing remediation text.

Counts reference encodes vs. generate calls — the whole point of the test. Mirrors the real model's contract: ``voice_clone_prompt`` and ``re

Node-side staging for one listener. Shared across panels.

Canned judge transport: returns queued raw strings.

Thread-safe, file-backed store of per-panel keys. Backed by a plain JSON file rather than the settings store because the settings store is re

Capacity bookkeeping for one (worker, model) pair.

One try of a task on one worker.

Deterministic transcriber for the harness's own offline tests. Either returns a fixed string, or echoes a per-path mapping. Lets us prove the

The gallery answered, and what it said cannot be trusted or used.

An illegal transition was attempted.

Which refinement behaviours to apply.

Remote work started and then failed. Rule 2: this is not a fallback. Carries what a caller needs to offer "Run locally instead" — the same re

Accumulates streaming tokens and yields complete sentences. Usage:: chunker = SentenceChunker() for token in llm_stream:

In-memory task dispatcher with SQLite-backed metadata. The dispatcher itself (queue + worker + listeners) stays in-memory for speed, but ever

A registration failure that reconnecting cannot repair.

Stands in for get_active_asr_backend; counts backend constructions — the expensive per-call model load the cache must eliminate.

Minimal ASR backend; `turns` simulates FunASR-style inline diarization.

Stands in for a warm mlx-whisper / sherpa recognizer.

All breakers for all workers, plus fleet-wide event detection. Session-scoped by design: OSS control planes restart constantly (the app quits

In-test subclass — runs the echo sidecar under `sys.executable`.

A single user utterance in a scripted conversation.

A managed executable failed pre-exec validation (missing, empty, or not a real executable), or the OS refused to exec it. The message is user-

A worker as the control plane knows it between connections.

Stands in for the active ASR backend's .transcribe() — no model, no network. `chunks_by_path` maps a ref_audio path to the canned chunk list t

Non-Off LLM stand-in that always returns one fixed reply; counts calls.

Mimics pyannote's `Annotation.itertracks(yield_label=True)`.

Model whose ``generate`` raises the given exceptions, in order, then succeeds.

A pasted inbound connection could not be validated or activated.

A failed connection change could not restore its prior generation.

IndexTTS 2.5 (Bilibili) — isolated subprocess with IndexTTS-2 fallback. Plan 02-03 migrated IndexTTS off the in-process import path because I

One panel→node session, reconnecting until told to stop.