mirror of
https://github.com/christianselig/apollo-backend
synced 2024-11-10 22:17:44 +00:00
tweak prefetch
This commit is contained in:
parent
cc1d932781
commit
07961c1199
1 changed files with 1 additions and 1 deletions
|
@ -79,7 +79,7 @@ func (nw *notificationsWorker) Start(consumers int) error {
|
||||||
"numConsumers": consumers,
|
"numConsumers": consumers,
|
||||||
}).Info("starting up notifications worker")
|
}).Info("starting up notifications worker")
|
||||||
|
|
||||||
prefetchLimit := int64(consumers * 32)
|
prefetchLimit := int64(consumers * 2)
|
||||||
|
|
||||||
if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {
|
if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
Loading…
Reference in a new issue