Ver código fonte

Last remaining fix.

Omer Katz 6 anos atrás
pai
commit
c8ef7ad60b
1 arquivos alterados com 1 adições e 1 exclusões
  1. 1 1
      celery/worker/worker.py

+ 1 - 1
celery/worker/worker.py

@@ -240,7 +240,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):