From 290b8c1854cfd2d7d042ff1b1849324a42663f18 Mon Sep 17 00:00:00 2001 From: wangbo Date: Fri, 24 Jul 2026 10:37:20 +0800 Subject: [PATCH] =?UTF-8?q?fix(queue):=20=E6=89=A9=E5=B1=95=E7=94=9F?= =?UTF-8?q?=E4=BA=A7=E5=AA=92=E4=BD=93=E4=BB=BB=E5=8A=A1=E5=90=9E=E5=90=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/api/internal/runner/queue_worker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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