Return a list of violation strings (empty = clean).

Return ``(ok, reason)`` — never raises. Checks the file exists, is non-empty, and starts with a known executable magic. This is placeholder/c

The worker's stream dropped. Start the grace window; fail nothing. This is the whole §10-vs-§21 fix in one method: we record that we have

Return a clean ``{key: respelling}`` dict. Drops entries whose key is empty or whitespace-only; coerces keys/values to stripped strings. A va

Pure, idempotent normalization pass (no pref gate — see :func:`normalize_for_tts` for the gated entry point pipelines call).

Map a free-text voice description onto the design parameter space. Returns a dict with: * ``attrs`` — full category → token map (``"Aut

Subtract the estimated echo from the near-end (mic) signal. Returns int16 little-endian mono PCM with the estimated echo removed. Pas

Read a JSONL test list file. Each line should be a JSON object with fields: id, text, ref_audio, ref_text, language_id, language_name, du

Record an unhandled exception. Returns the (scrubbed) journal entry. Never raises — this runs inside the global exception handler, where a se

Normalized remote operator key, read dynamically for rotation support.

ONE clone reference for every segment of `speaker_key`. Preference order: 1. the pooled per-speaker clone (job["speaker_clones"]) — same lo

`(status, reason)` when a synth-time notice SHOULD be surfaced to the user, else `None`. Surfaced for `cpu_fallback` (always) and for `acceler

Drop-in replacement for ``asyncio.create_subprocess_exec``. Falls back to a thread-based ``subprocess.Popen`` (wrapped to match the asyncio P

Run a teardown while holding the same lifecycle ownership every spawn path uses. Reset, Clean & Retry, setup re-entry, uninstall, and app exit join la

Run one segmented_download against a mock origin in a fresh event loop.

Bind should_torch_compile's dependencies to a controlled fake.

The local copy of one input, downloaded only if we lack it. Content-addressed: the name is the hash the control plane computed, so a

Persist a rename/create where the platform supports directory fsync.

TTSBackend stub whose output is a pure function of the input text, so the streamed per-chunk renders and the classic whole-request render can be

Build a fresh TTSBackend stub class. Fresh per call so the per-process instance cache in api.routers.engines can't leak state across tests.

Patch huggingface_hub.whoami so that a known {token: result} mapping drives validity. `mapping[token]` may be a dict like {"name": "alice"} or

Stand-in preview bytes — content is irrelevant, its digest is not.

Select the subset of a speaker's segments to use as reference audio. Strategy: rank candidates clean-first (not temporally adjacent to a diff

A mock origin that honours Range requests over `payload`.

`alembic upgrade head` on startup, wrapped in the data-safety net. Failure classes are handled differently on purpose: - alembic unavailable

Create a job, append some progress events + a final done event, mark done.

A user DB with real data (and optionally a stamped alembic revision). Seeds the full base schema — in the real startup order ``init_db`` lays

Job segments with `text` overlaid from ``job["segments_i18n"][lang]``. P1.2 — ``job["segments"]`` is single-slot: it holds whichever language was

Return the persisted stretch plan + total durations for `lang_code`, or None if this job didn't use stretch_video mode (or no plan exists).

Build a temp SRT from job segments for use with ffmpeg's subtitles filter. Returned path is already ffmpeg-filter-safe (plain ASCII basename unde

Write a mono wav from (amplitude, seconds) segments; return its path.

Fabricate a weights dir; ``complete=True`` adds the completion marker the installer writes after snapshot_download returns.

Resolve ``[[…]]`` one-off pronunciation overrides to plain spoken text. ``[[term|replacement]]`` → ``replacement`` (the ``term`` half is a label

One ffmpeg filter chain mixing `voice_in` over `bed_in` at original level. `bed_in`/`voice_in` are filtergraph input labels ("0:a", "1:a", …); `o

Build the split/trim/setpts/concat filter graph for ``chunks``. With all keyword options at their defaults the output is byte-identical to th

Deterministic content hash for a chapter's rendered audio. ``spans`` is an ordered list of ``(voice_id, text, pause_ms_after[, speed])`` (spe

Insert ``# `` headings ahead of obvious chapter-title lines. No-op if the text already has Markdown H1 headings (the user has structured it).

Constant-time credential comparison that accepts the full Unicode range.

Convert EPUB bytes into a ``# Chapter`` / body script in spine order. Reads the OPF manifest + spine (the publisher's reading order), extracts

Register a fake engine in the REAL registry so resolve_generation_backend exercises the actual lookup/is_available/routing/cloning chain, not a st

Deterministic hash of the fit configuration for one dub track. Canonicalised with the same `_canon_value` rules as segment fingerprints (int

Flush remaining buffer as final sentence(s). Call at end of stream.

Generate speech audio given text in various modes. Supports three modes: 1. **Voice clone** — clone the voice style from the referen

True when *reason* looks like a network/connectivity failure of an HF download (DNS, refused/reset connections, timeouts, hub locate errors).