airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Craig Rodrigues <>
Subject celery problem, AttributeError: async
Date Mon, 21 May 2018 07:20:50 GMT

I used a requiremens.txt file with these three lines:


I did

pip install -r requirements.txt

When I started my worker, I got:

[2018-05-21 06:39:23,980] {} INFO - Using executor CeleryExecutor
Traceback (most recent call last):
  File "/bin/airflow", line 32, in <module>
  File "/usr/lib/python2.7/site-packages/airflow/utils/", line 74, in wrapper
    return f(*args, **kwargs)
  File "/usr/lib/python2.7/site-packages/airflow/bin/", line 959, in worker**options)
  File "/usr/lib/python2.7/site-packages/celery/bin/", line 257, in run
  File "/usr/lib/python2.7/site-packages/celery/worker/", line 101, in __init__
  File "/usr/lib/python2.7/site-packages/celery/worker/", line 124, in setup_instance
    self.should_use_eventloop() if use_eventloop is None
  File "/usr/lib/python2.7/site-packages/celery/worker/", line 243, in should_use_eve
    self._conninfo.transport.implements.async and
  File "/usr/lib/python2.7/site-packages/kombu/transport/", line 125, in __getattr__
    raise AttributeError(key)
AttributeError: async

I reported this as a bug in celery here:

It turns out that this is a known problem.  It looks like in kombu, they
renamed a bunch of uses of "async" to "asynchronous", to not clash with the new
'async' keyword in Python 3.7.

In celery, they are catching up and doing the same rename.  
Almost at the same time that I reported this bug, the issue was fixed in the master branch
of celery:

Hopefully the versions of kombu and celery will stabilize so that it all works properly with


View raw message