tapir

Files

T

mathiasandClaude Sonnet 5.5 a8dadb8ca4 feat(uploads): in-process transcription worker, one job at a time (ADR-033)

Queue -> StartTranscribing -> ffmpeg to 16 kHz WAV -> gateway chain ->
CompleteUpload, with a per-job timeout so a hung endpoint ends in failed, not
a spinner. The upload and the WAV are deleted on every path (audio is never
retained). A shutdown mid-job is not a failure: the row is left for the
start-up sweep. Cancellation wins over a non-empty queue, so queued jobs are
never started on shutdown; stop() deletes their audio and refuses new jobs.

Concurrency is 1 on purpose: two simultaneous long jobs on iguana were never
measured, and a Metal OOM there latches whisper (infra#273). The queue is
process-local, so ADR-018's single-replica assumption now has a second
dependent.

Mutation-checked, -race clean: cleanup, shutdown-vs-failure, timeout,
concurrency and stop-cleanup each turn a test red.

Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>

2026-10-01 16:54:52 +02:00

intake_test.go

test(uploads): Accept -- size cap, probe verdicts, cleanup on every failure path (red)

2026-10-01 16:40:03 +02:00

intake.go

feat(uploads): Intake -- spool, probe, validate, queue; clean up on every failure (ADR-033)

2026-10-01 16:40:13 +02:00

validate_test.go

test(uploads): validation policy -- video, no-audio, too-long, unreadable (red)

2026-10-01 16:39:20 +02:00

validate.go

feat(uploads): validation policy for probed audio uploads (ADR-033)