Build an FFMETADATA1 doc: optional global tags + one ``[CHAPTER]`` per ``(title, duration_ms)``. START/END are cumulative millisecond offsets.

Build the newest-first list of finished longform renders. Pure over the two job-store callables so tests can pass them directly: * ``list_jo

Return the absolute time (s) of the first speech-like frame inside ``[start_s, end_s]``, or ``None`` when the window is empty / silent. "Spee

Forget a registration whose worker never confirmed acceptance.

Per-segment dub WAV path keyed by the STABLE segment id (not its list index), so partial regeneration reuses the right audio after a delete/me

Locate an ffprobe binary (legacy wrapper around :func:`resolve_ffprobe`). Falls back to deriving the path from ``find_ffmpeg()`` so the co-lo

``model.generate()`` with the reference clip encoded once, not once per call. The native (non-adapter) callers of the OmniVoice model — ``/genera

Dedicated 1-worker pool for provenance marking. Built lazily so hosts with watermarking disabled never spawn the thread. The executor is capt

:func:`get_active_asr_backend` + eager ``ensure_loaded()``, degrading past backends whose deep import chain is broken (#1185). ``is_available

Return a selector that is currently visible, self-healing if needed.

Free idle GPU memory before a warm, heavy generate (#730/#1190). The cold LOAD path already evicts (``_make_room_before_tts_load`` runs inside

Per-engine managed install root (checkout lives inside it).

Decode once and compute every cheap stat the audio judges need.

Return a safe SPDX id: the value if it's allowlisted or a ``LicenseRef-`` custom id, else :data:`DEFAULT_LICENSE`. Never raises, never 400s — a ju

Reconcile against what the worker says it is running. Returns attempt ids the worker should cancel — work we have already written off

Split chunks into order-preserving batches of at most ``batch_size``.

Convert PDF bytes into a ``# Chapter`` / body script. Extracts the embedded text layer page-by-page (in page order), joins it, and runs it th

Just "something is listening on :port"

Return 0-indexed position among queued jobs, or -1 if not queued.

Computes WER and related metrics for a single hypothesis-truth pair. Args: hypothesis (str): The transcribed text from the ASR model

Evict the oldest files in ``cache_dir`` until the total size is within ``max_bytes`` (LRU by mtime). The content-addressed render cache otherwise

Return fixed remediation selected by a stable failure taxonomy. Classification may inspect the private diagnostic locally, but response value

Log fixed failure metadata and return a fixed public failure message. ``response`` must be authored by VoiceStudio, never derived from ``error``.

Shut down sidecars idle longer than ``timeout_s``. Returns the count reaped. A non-positive timeout disables reaping (returns 0). Safe to call

Most recent errors first.

Record a measured round trip and republish the median. Median, not mean: a consumer link jitters, and a worker busy loading a model a

Silence removal that can never consume the whole recording (issue #1188). :func:`remove_silence` detects speech against a fixed dBFS threshold. A

Return the candidate SHA, or ``None`` if no commit matches. Walks up to ``max_commits`` commits newest-first. The first commit whose tree con

Reload tasks that were live when the control plane stopped. They are NOT failed on the way in — unlike local jobs, the machine doing

Return the immutable revision for a curated repo, or raise.

Match the second-pass recognition to the dub segments and score drift. ``dub_segments`` are the segments we generated (each {start, end, text});

Return stable stream metadata selected only from an internal code.

Can this worker run this work at all? ``supported`` alone is not enough — an engine whose weights are not on disk cannot start withou

Install the production SPA beside `backend/`, where the Python server's static-file mount resolves it for Network Sharing clients.

Trim trailing near-silence from a generated clip, keeping a short natural tail of ``keep_tail_s`` seconds after the last voiced sample. Ampli

Environment for ``uv`` subprocesses that install into *cache_parent*'s volume. Returns ``None`` (inherit the parent environment untouched) when u

Split segments at scene cuts only if both halves remain viable.

Return a character offset to split at. Prefer sentence > clause > word. Scans the full text for each candidate class and picks the one whose offs

Concatenate audio chunks and write to a temp WAV file. Handles both raw PCM (from AudioWorklet) and WebM/Opus blobs (from MediaRecorder) by c

An artifact the worker names is only ever a reference into our own store, and is resolved as one.

Patch the three eviction primitives and count how often each runs.