Ver código fonte

Consumer: Task bootstep must require Events

Ask Solem 11 anos atrás
pai
commit
0fa0279e0d
1 arquivos alterados com 1 adições e 1 exclusões
  1. 1 1
      celery/worker/consumer.py

+ 1 - 1
celery/worker/consumer.py

@@ -490,7 +490,7 @@ class Control(bootsteps.StartStopStep):
 
 
 
 
 class Tasks(bootsteps.StartStopStep):
 class Tasks(bootsteps.StartStopStep):
-    requires = ()
+    requires = (Events, )
 
 
     def __init__(self, c, initial_prefetch_count=2, **kwargs):
     def __init__(self, c, initial_prefetch_count=2, **kwargs):
         c.task_consumer = c.qos = None
         c.task_consumer = c.qos = None