Parcourir la source

Last remaining fix.

Omer Katz il y a 6 ans
Parent
commit
eda5556142
1 fichiers modifiés avec 1 ajouts et 1 suppressions
  1. 1 1
      celery/worker/worker.py

+ 1 - 1
celery/worker/worker.py

@@ -242,7 +242,7 @@ class WorkController(object):
 
     def should_use_eventloop(self):
         return (detect_environment() == 'default' and
-                self._conninfo.transport.implements.async and
+                self._conninfo.transport.implements.asynchronous and
                 not self.app.IS_WINDOWS)
 
     def stop(self, in_sighandler=False, exitcode=None):