Call confirm_delivery only once per channel

alephdata · Jul 1, 2024 · 9a67b5a · 9a67b5a
1 parent 8b522b7
commit 9a67b5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -736,6 +736,7 @@ def get_rabbitmq_channel() -> BlockingChannel:
                 )
                 local.connection = connection
                 local.channel = connection.channel()
+                local.channel.confirm_delivery()
 
             # Check that the connection is alive
             result = local.channel.exchange_declare(
@@ -826,7 +827,6 @@ def queue_task(
         "priority": priority,
     }
     try:
-        rmq_channel.confirm_delivery()
         rmq_channel.basic_publish(
             exchange="",
             routing_key=stage,