From 5d5284e068691659ce4af8cf4358a71b8792cf7e Mon Sep 17 00:00:00 2001 From: wangbo Date: Wed, 29 Jul 2026 03:07:13 +0800 Subject: [PATCH] =?UTF-8?q?test(api):=20=E6=98=BE=E5=BC=8F=E5=90=AF?= =?UTF-8?q?=E7=94=A8=E5=BC=82=E6=AD=A5=E6=89=A7=E8=A1=8C=E9=AA=8C=E6=94=B6?= =?UTF-8?q?=20Worker?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 动态并发验收直接构造 Config 时需显式开启 AsyncQueueWorkerEnabled,避免零值 false 把该测试误变为仅入队模式。\n\n验证:gofmt、go test ./internal/httpapi -count=1。 --- .../internal/httpapi/async_worker_acceptance_integration_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/api/internal/httpapi/async_worker_acceptance_integration_test.go b/apps/api/internal/httpapi/async_worker_acceptance_integration_test.go index 3210ab7..38684b1 100644 --- a/apps/api/internal/httpapi/async_worker_acceptance_integration_test.go +++ b/apps/api/internal/httpapi/async_worker_acceptance_integration_test.go @@ -54,6 +54,7 @@ func TestAsyncWorkerDynamicConcurrencyAcceptance(t *testing.T) { JWTSecret: "test-secret", BillingEngineMode: "observe", CORSAllowedOrigin: "*", + AsyncQueueWorkerEnabled: true, AsyncWorkerHardLimit: 256, AsyncWorkerRefreshIntervalSeconds: 1, }, db, slog.New(slog.NewTextHandler(io.Discard, nil))))