Просмотр исходного кода

Improves info message after add_consumer

Ask Solem 11 лет назад
Родитель
Сommit
4cdb7f1c62
1 измененных файлов с 2 добавлено и 1 удалено
  1. 2 1
      celery/worker/consumer.py

+ 2 - 1
celery/worker/consumer.py

@@ -389,9 +389,10 @@ class Consumer(object):
         if not cset.consuming_from(queue):
         if not cset.consuming_from(queue):
             cset.add_queue(q)
             cset.add_queue(q)
             cset.consume()
             cset.consume()
-            info('Started consuming from %r', queue)
+            info('Started consuming from %s', q)
 
 
     def cancel_task_queue(self, queue):
     def cancel_task_queue(self, queue):
+        info('Cancelling queue %s', q)
         self.app.amqp.queues.deselect(queue)
         self.app.amqp.queues.deselect(queue)
         self.task_consumer.cancel_by_queue(queue)
         self.task_consumer.cancel_by_queue(queue)