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,