Bound an advertised concurrency value to the server's safe range.

Parse SRT text and return cleaned, non-overlapping segments. - Skips cues with non-positive duration or unparseable timestamps. - When two cu

Normalise one dictation final. Empty/whitespace-only input -> ``""``.

Record a failure. Returns True if the breaker opened as a result.

A client that is never connected; only its outbox is read.

Point the route's gateway calls at the fake, with a fixed decision.

Replace the real agent's start/stop/registration with recorded no-ops. `fail` makes `start()` raise (a token that cannot even be redeemed); `

Build a torch-module mock with a controllable accelerator shape.

Write a WAV to ``target_path`` atomically. Implementation: write to a sibling temp file in the same directory, then ``os.replace()`` into pla

Mint a join token carrying this control plane's fingerprint.

One line for the UI. A breaker the user cannot understand is worse than no breaker at all.

Return the effect chain for a preset. Falls back to empty chain.

Gated + hardened entry point: pref/env toggle, never raises. Every TTS pipeline calls this exactly once, at its text→engine choke point, BEFO

Validate the ZIP and read manifest/consent WITHOUT touching the DB or writing files. Raises :class:`BundleError` (400|413) for B1-B11. The caller

Run blocking ``fn`` on the GPU pool, bounding **execution** — not the wait for a free worker. Two clocks (#1190/#1202): * ``queue_timeou

Split *text* at natural boundaries into chunks of at most *max_chars*. Priority: sentence-end (``.!?`` not after an abbreviation/decimal and not

Block until ``task_id`` reaches a terminal state, and return it. Raises ``KeyError`` for a task this scheduler does not hold, ``Timeo

Bidirectional control stream. A coroutine (not an async generator) so that reads and writes can run as independent tasks: outbound as

Stub the OpenAI SDK's models.list for the discovery path.

Serialize a worker's frames with its durable lifecycle handoff.

Replace whole-word occurrences of each lexicon key with its respelling. Case-insensitive match; word-boundary aware (a key never matches inside a

Split ``text`` on inline ``[pause ...]`` markers (issue #276). Returns a list of ``(span_text, pause_ms_after)`` tuples, in order, where ``pa

Return a portable bare filename, rejecting traversal and drive paths.

Enforce leases, grace windows, and task deadlines. Called on a timer. Everything time-based happens here rather than being scattered

Serialize publication of one attempt across retained generations.

Apply a chain of named effects to an audio tensor. Each item in `chain` is a dict with a `type` key and effect-specific parameters. Unknown t

Mint the same one-shot file capability written by the Tauri process.

Strip STT-artifact loops. Two passes handle the full space: 1. Word-level: any token repeated ``min_run``+ times consecutively (with surro

Durably commit an attempt's result. Returns ``(committed, attempt)``. ``committed`` is False when another attempt already won — the c

Compute the deadlines for one attempt. ``model_resident`` and ``model_downloaded`` matter enormously: a warm model is ~8s away, a cold one mi

Peak-normalizes the audio to a standard broadcasting level (-2 dB) to fix F5TTS volume fluctuations. Never amplifies a near-silent signal. A fail

Send a batch dict (containing _req_id + _batch) for processing.

Patch the synth + OUTPUTS_DIR, drive the real generator, return parsed SSE events (list of dicts). Bounded on purpose. One of the failures th

The canonical HF cache layout for ``repo_id``, with one healthy blob, one healthy snapshot link, one healthy regular file — and no breakage yet.

chapters: (title, body) pairs → AudiobookPlan.

One segment [0, slot] covering the whole video — no slack, no tail.

Pure argv for muxing chapter WAVs + FFMETADATA into a tagged, chapter-marked audio file. Inputs: 0 = concat-demuxer list of chapter WAVs, 1 =

Wait for ``task`` even if the waiter is cancelled again.

Evaluation loop.

Detect the best available compute device. Priority: CUDA/ROCm > Intel XPU > DirectML > MPS > CPU The *family* decision delegates to ``core.d

Parse a pasted connection string, or explain what is wrong with it.

Plan the Smart Fit layout for a dub track. ``segments``: original-timeline segments in chronological order, each a dict with ``id``, ``start`

Persist a pasted node secret outside the UI-readable settings store.

Extend the lease by ``seconds``, never past ``not_after``. The ceiling is what separates "still alive" from "still working": a keepal

Run a blocking transcribe ``fn`` in ``executor`` with a hard wall-clock bound. On timeout, raise :class:`ASRTimeoutError` with guidance instead of