From d80b2e5ebf871baef6b6c48b4b54313b27cea028 Mon Sep 17 00:00:00 2001 From: wangbo Date: Fri, 24 Jul 2026 10:31:18 +0800 Subject: [PATCH] =?UTF-8?q?fix(queue):=20=E6=8F=90=E5=8D=87=E5=AA=92?= =?UTF-8?q?=E4=BD=93=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C=E5=B9=B6=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/api/internal/runner/queue_worker.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/apps/api/internal/runner/queue_worker.go b/apps/api/internal/runner/queue_worker.go index 6809d7e..17a9d34 100644 --- a/apps/api/internal/runner/queue_worker.go +++ b/apps/api/internal/runner/queue_worker.go @@ -97,7 +97,11 @@ func (s *Service) startRiverQueue(ctx context.Context) error { Logger: s.logger, CompletedJobRetentionPeriod: 24 * time.Hour, Queues: map[string]river.QueueConfig{ - asyncTaskQueueName: {MaxWorkers: 32}, + // Image providers may hold a worker while polling for several + // minutes. Keep enough workers available for production bursts so + // unrelated models do not remain queued behind long-running media + // tasks. + asyncTaskQueueName: {MaxWorkers: 64}, }, // 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