Map a failure reason to a docs-taxonomy key, or "" when unknown. Heuristic substring match — mirrors the frontend ``classifyError`` so the ba

Re-render one preview: same key, different bytes — the update case.

Split ``payload`` into offset-correct chunks.

Join on first call, prove key possession on every later one.

Persist a freshly rendered segment. Best-effort — a full disk or unwritable cache dir must never fail the chapter render. ``nonce`` ma

Richer stub carrying the channels the admin-credential check reads: headers, query params, cookies, and app.state.network_share.pin.

Create the next attempt on ``worker_id``.

Configure + activate a remote provider directly through the store.

Locate an ffmpeg binary. Resolution order: 1. ``FFMPEG_PATH`` env var (set by Tauri when a sidecar is bundled, or by the user's Se

Cached audio tensor for ``span``, or ``None`` (miss). A hit bumps the file's mtime so LRU eviction sees the segment as recently used.

Parse a chapter-delimited script into an :class:`AudiobookPlan`. Thin wrapper over the canonical :func:`services.longform_parser. parse_scrip

Best-effort cache flush + the user-facing OOM hint shared by both inference paths.

* `apiFetch` deliberately returns the raw Response and sets no Content-Type — * it preserves the call shape so FormData posts keep working. Every JSO

Resolve and attach the single authentication decision for one scope.

Extract one message body by matching braces. Brace counting rather than a lazy regex: several messages are written on a single line, and ``.*

Return a slot. ``zombie=True`` parks it instead: the task is over but the GPU thread is not, so the capacity is still gone. Returns w

Single audited torchaudio.save wrapper. Closes BUG-01 / issue #48. The caller hands us a tensor that may have come from a GPU model, may have

Return the matching live key, or None. Compares against every stored key in constant time and does not stop at the first match. Short

Send an assignment to its worker. False if the stream is gone.

Revoke one panel's key. Others keep working — that is the point.

Resolve the exact registration response an inbound node accepted.

Enqueue a frame. ``bulk`` is for anything that can be large. Only result frames qualify today. Everything else — heartbeat, pong, pro

Minimal torch mock: CUDA build when ``hip`` is None, else a ROCm build.

Run the bootstrap on a thread; the returned closure joins it with a hard timeout so a wiring regression fails red instead of hanging CI.

Return the raw Whisper output dict. Callers (`segment_transcript`) know how to read it — this stays deliberately untyped so new engines

Apply the pronunciation dictionary + inline overrides to ``text``. Order (load-bearing): 1. DB dictionary rows (``entries``) filtered to ``

A ``Content-Disposition`` value that is safe for ANY filename (#1262). Emits both forms per RFC 6266 §4.3: ``filename=`` for the lowest common

Cached per-process host capabilities. Never raises, makes no network call, kernel-free on cold start. Host compute capability does not change at

Enumerate every registered backend with its availability state. Per-entry shape (ENGINE-05 + ENGINE-06): { "id": s

Prober from {endpoint: latency_ms | None (unreachable)}; counts calls.

Pick the best eligible worker, or explain why there is none. The two "nothing available" cases are deliberately distinguished: all wo

Build the structured failure fields (no ``type`` — caller/prep_event adds it). ``reason`` is guaranteed non-empty: ``str(exc)`` → exception class

Join per-chunk waveforms with a linear crossfade on the sample axis. ``chunks`` are torch tensors as returned by the engine (1-D, or N-D with

Split one line of SSML-LITE markup into ordered prosody segments. See the module docstring for the full contract. Always returns at least one

Stage a finished result and return the ref that names it.

Snap each segment's ``start`` forward to the actual speech onset. Mutates the segment dicts in place (the shape the dub pipeline passes aroun

Publish a registered worker only once its stream is opening.

A published-asset list, with each artifact's `.sig` companion.

Read one frame from the sidecar's stdout. Returns None on EOF. Op allowlist is enforced here: unknown ops are logged and dropped, and

Render one chapter, content-addressed so a re-run reuses it (resume). Returns ``(wav_path, duration_s, was_cached, seg_stats)``. Two cache la