From 6a2df4837b3925b502401911725b08d3d21aa78c Mon Sep 17 00:00:00 2001 From: team-humaki Date: Fri, 11 Sep 2026 15:59:47 -0700 Subject: [PATCH] fix: drop trailing comma in queue worker_num setting key Queue() looked up queue__worker_num, which never matched the stored setting, so WorkerNum always fell back to 15. --- pkg/setting/provider.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/setting/provider.go b/pkg/setting/provider.go index e9816c45..5fb80a5a 100644 --- a/pkg/setting/provider.go +++ b/pkg/setting/provider.go @@ -663,7 +663,7 @@ func (s *settingProvider) FTSChunkSize(ctx context.Context) int { func (s *settingProvider) Queue(ctx context.Context, queueType QueueType) *QueueSetting { queueTypeStr := string(queueType) return &QueueSetting{ - WorkerNum: s.getInt(ctx, "queue_"+queueTypeStr+"_worker_num,", 15), + WorkerNum: s.getInt(ctx, "queue_"+queueTypeStr+"_worker_num", 15), MaxExecution: time.Duration(s.getInt(ctx, "queue_"+queueTypeStr+"_max_execution", 86400)) * time.Second, BackoffFactor: s.getFloat64(ctx, "queue_"+queueTypeStr+"_backoff_factor", 4), BackoffMaxDuration: time.Duration(s.getInt(ctx, "queue_"+queueTypeStr+"_backoff_max_duration", 3600)) * time.Second,