From b98f8345a52d2c00ef61960a17ddee6ca9e2d4bb Mon Sep 17 00:00:00 2001
From: Andre Medeiros <me@andremedeiros.info>
Date: Tue, 13 Jul 2021 19:48:23 -0400
Subject: [PATCH] don't prefetch as much

---
 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 3d01c43..176e830 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 * 8)
+	prefetchLimit := int64(consumers * 2)
 
 	if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {
 		return err