Преглед на файлове

Disable mediator inside of eventloop

Ask Solem преди 13 години
родител
ревизия
df92aef158
променени са 1 файла, в които са добавени 3 реда и са изтрити 3 реда
  1. 3 3
      celery/worker/mediator.py

+ 3 - 3
celery/worker/mediator.py

@@ -39,9 +39,9 @@ class WorkerComponent(StartStopComponent):
         w.mediator = None
 
     def include_if(self, w):
-        return (not w.disable_rate_limits or
-                w.pool_cls.requires_mediator and
-                not w.use_eventloop)
+        return ((not w.disable_rate_limits or
+                w.pool_cls.requires_mediator) and
+                    not w.use_eventloop)
 
     def create(self, w):
         m = w.mediator = self.instantiate(w.mediator_cls, w.ready_queue,