Переглянути джерело

Renamed remote control command worker_queues -> active_queues

Ask Solem 14 роки тому
батько
коміт
96b6315ace
2 змінених файлів з 3 додано та 3 видалено
  1. 2 2
      celery/task/control.py
  2. 1 1
      celery/worker/control/builtins.py

+ 2 - 2
celery/task/control.py

@@ -70,8 +70,8 @@ class Inspect(object):
     def cancel_consumer(self, queue, **kwargs):
         return self._request("cancel_consumer", queue=queue, **kwargs)
 
-    def worker_queues(self):
-        return self._request("worker_queues")
+    def active_queues(self):
+        return self._request("active_queues")
 
 
 class Control(object):

+ 1 - 1
celery/worker/control/builtins.py

@@ -217,6 +217,6 @@ def cancel_consumer(panel, queue=None, **_):
 
 
 @Panel.register
-def worker_queues(panel):
+def active_queues(panel):
     """Returns the queues associated with each worker."""
     return dict(panel.consumer.queues.iteritems())