test

JetDrag · Apr 24, 2024 · 073e824 · 073e824
1 parent 98faa32
commit 073e824
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dramatiq/brokers/rabbitmq.py b/dramatiq/brokers/rabbitmq.py
@@ -218,7 +218,7 @@ def consume(self, queue_name, prefetch=1, timeout=5000):
         Returns:
           Consumer: A consumer that retrieves messages from RabbitMQ.
         """
-        self.declare_queue(queue_name, ensure='strict')
+        self.declare_queue(queue_name, ensure="strict")
         return self.consumer_class(self.parameters, queue_name, prefetch, timeout)
 
     def declare_queue(self, queue_name, *, ensure=False):
@@ -246,7 +246,7 @@ def declare_queue(self, queue_name, *, ensure=False):
             self.emit_after("declare_delay_queue", delayed_name)
 
         if ensure:
-            self._ensure_queue(queue_name, ensure=="strict")
+            self._ensure_queue(queue_name, ensure == "strict")
 
     def _ensure_queue(self, queue_name, strict=False):
         attempts = 1