From 07961c1199a006742f846fed6aa16543c3fa609e Mon Sep 17 00:00:00 2001
From: Andre Medeiros <me@andremedeiros.info>
Date: Tue, 13 Jul 2021 19:41:29 -0400
Subject: [PATCH] tweak prefetch

---
 internal/worker/notifications.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go
index 546dbc0..53c0742 100644
--- a/internal/worker/notifications.go
+++ b/internal/worker/notifications.go
@@ -79,7 +79,7 @@ func (nw *notificationsWorker) Start(consumers int) error {
 		"numConsumers": consumers,
 	}).Info("starting up notifications worker")
 
-	prefetchLimit := int64(consumers * 32)
+	prefetchLimit := int64(consumers * 2)
 
 	if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {
 		return err