decrease the worker limit for the ennoblementsQueue

2021-05-12 15:50:21 +02:00 · 2021-05-12 15:50:21 +02:00 · 07961fe2f3
parent e38704663c
commit 07961fe2f3
1 changed files with 1 additions and 1 deletions
--- a/internal/cron/queue/queue.go
+++ b/internal/cron/queue/queue.go
@ -47,7 +47,7 @@ func New(cfg *Config) (Queue, error) {
 func (q *queue) init(cfg *Config) error {
 	q.factory = redisq.NewFactory()
 	q.mainQueue = q.registerQueue(MainQueue, cfg.WorkerLimit)
-	q.ennoblementsQueue = q.registerQueue(EnnoblementsQueue, cfg.WorkerLimit*2)
+	q.ennoblementsQueue = q.registerQueue(EnnoblementsQueue, cfg.WorkerLimit)

 	return nil
 }