Procházet zdrojové kódy

Used internal interface for queue_delete

Ask Solem před 14 roky
rodič
revize
ffe24d5ddd
1 změnil soubory, kde provedl 3 přidání a 1 odebrání
  1. 3 1
      celery/backends/amqp.py

+ 3 - 1
celery/backends/amqp.py

@@ -151,7 +151,9 @@ class AMQPBackend(BaseDictBackend):
         result = consumer.fetch()
         try:
             if result:
-                consumer.queue_delete(True, True)
+                consumer.backend.queue_delete(queue=consumer.queue,
+                                              if_unused=True,
+                                              if_empty=True)
                 payload = self._cache[task_id] = result.payload
                 return payload
             else: