True when the dictation model produced NO text despite real speech. Distinguishes "the user said nothing" (fine — stay quiet) from "the model

The grace window expired without word from the worker. Unknown outcome, not failure: the worker is excluded (we cannot ask it again)

The verdict: only blocking failures matter.

Append far-end (playback) audio to the reference ring buffer. Accepts raw int16 little-endian mono PCM at the configured rate.

Prepend `marker` and keep only the newest [`MAX_MARKERS`]. Pure so the rotation policy is unit-tested without touching the filesystem.

Re-probe and publish after model/download/residency changes.

Take the port back and bring a healthy backend up on it, from scratch if need be. Shared by the Retry button and by a scoped reset (`reset.rs`), which

Drop a result only after the panel acknowledges its task commit.

Redact secrets and strip the home path from a string. - HF tokens (reuses the regex from ``core.logging_filter``) - values of env vars whose

Hand a previously pushed input to the executor. Copied rather than moved: an attempt that is retried asks for the same input again, a

Enqueue a coroutine-returning callable. Idempotent on job_id.

Render a chapter's spans to one waveform via an injected ``synth``. ``synth(text, voice_id, speed)`` returns a float32 audio tensor — 1-D ``(

Normalized token edit distance in [0.0, 1.0+]. 0.0 = the ASR heard exactly the target text. ~1.0 = entirely different. Can exceed 1.0 when th

Overlay fitted cue times onto subtitle segments (copies; non-destructive). Matches by segment ``id``; when the fitted record carries no ids at al

Check if AudioSeal is installed and importable.

Re-implement the inline clamp from dub_export.py so we can unit-test it without standing up a full FastAPI app + ffmpeg subprocess.

Create a directory chain and persist each new parent entry.

Resolve a task for an inbound message, dropping stale sessions.

Fake `argostranslate` translating en→es to `[es]<text>` offline.

Whether a failed download attempt is worth retrying. Decides by CLASSIFICATION, not by exception type. The type-based tuple this replaced — `

Import services.tts_backend without forcing the heavy engine deps that some subclasses pull in at module import. We don't need a live engine t

Create a fake venv layout with a real Python executable symlink. Returns the path to the venv's python executable. The python is a symlink to

mlx-audio is Apple-Silicon-gated; force is_available()=True + a CPU-friendly host so the routing gate doesn't block these tests on non-mac CI

Render an archetype's sample script to ``out_path`` using the live engine. Reuses generation.py's inference primitives so there is exactly one TT

Synthesize ``[(text, pause_ms), ...]`` spans and stitch silence between them (issue #276). ``gen_span(text) -> torch.Tensor`` synthesizes one

Whether this process is a headless server deployment (Docker image). In Docker the loopback gate is *unenforceable*: Docker's network NAT rew

POST /generate with stream=true; return [(event_dict, recv_time), ...].

Sidecars expect a torch tensor (they call .detach()).

A terminal ack that commits nothing and says why. Refusals are answered rather than aborted: the ack is the only frame this RPC ever sends ba

Venv python path, per-OS layout (Windows: Scripts/, POSIX: bin/).

Common monkeypatching for driving the stream happy path end-to-end.

Assign speaker_id by overlap against a list of ``{start, end, speaker}`` turns produced by an ASR backend that diarizes inline (e.g. FunASR's cam+

Free/total memory right now. Never raises; fields absent when unknown. Always includes system RAM (``ram_available_gb`` / ``ram_total_gb``). On a

Where the listener binds. Localhost by default, which is nearly useless on its own — that is the point. Reaching this node from another machi