From 5f9a60f368d653a37eddfc5a59c3000b1516d6f6 Mon Sep 17 00:00:00 2001
From: Sean Shahkarami <sean.shahkarami@gmail.com>
Date: Wed, 9 Apr 2025 15:03:19 -0500
Subject: [PATCH] set prefetch count to 2 x max publish batch size

---
 loader.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/loader.py b/loader.py
index 5a17347..cbf122b 100644
--- a/loader.py
+++ b/loader.py
@@ -198,6 +198,7 @@ def main():
         logging.info("connected to rabbitmq")
 
         ch = conn.channel()
+        ch.basic_qos(prefetch_count=2 * args.max_batch_size)
         ch.queue_declare(args.rabbitmq_queue, durable=True)
         ch.queue_bind(args.rabbitmq_queue, args.rabbitmq_exchange, "#")