Przeglądaj źródła

consumer: Fixed error 'No such attribute channel_errors'

Ask Solem 14 lat temu
rodzic
commit
dc2619088b
1 zmienionych plików z 3 dodań i 2 usunięć
  1. 3 2
      celery/worker/consumer.py

+ 3 - 2
celery/worker/consumer.py

@@ -220,8 +220,9 @@ class Consumer(object):
         self.pidbox_node = self.app.control.mailbox.Node(self.hostname,
         self.pidbox_node = self.app.control.mailbox.Node(self.hostname,
                                                          state=pidbox_state,
                                                          state=pidbox_state,
                                                          handlers=Panel.data)
                                                          handlers=Panel.data)
-        self.connection_errors = \
-                self.app.broker_connection().connection_errors
+        conninfo = self.app.broker_connection()
+        self.connection_errors = conninfo.connection_errors
+        self.channel_errors = conninfo.channel_errors
         self.queues = queues
         self.queues = queues
 
 
     def start(self):
     def start(self):