diff --git a/apps/api/internal/runner/queue_worker.go b/apps/api/internal/runner/queue_worker.go index 17a9d34..e2b54a0 100644 --- a/apps/api/internal/runner/queue_worker.go +++ b/apps/api/internal/runner/queue_worker.go @@ -101,7 +101,7 @@ func (s *Service) startRiverQueue(ctx context.Context) error { // minutes. Keep enough workers available for production bursts so // unrelated models do not remain queued behind long-running media // tasks. - asyncTaskQueueName: {MaxWorkers: 64}, + asyncTaskQueueName: {MaxWorkers: 96}, }, // Provider-backed media jobs commonly poll for 10-20 minutes. River may // execute a still-running job again once this window elapses, so keep the