Search code examples
airflowmwaa

MWAA Apache Airflow DAG error importing EcsOperator

I am trying to deploy an Airfow DAG to MWAA.

My requirements.txt:

apache-airflow[amazon] == 3.2.0

I import EcsOperator like this:

from airflow.contrib.operators.ecs_operator import EcsOperator

However, I get this error:

Broken DAG: [/usr/local/airflow/dags/mydag.py] Traceback (most recent call last):
  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/usr/local/airflow/dags/mydag.py", line 4, in <module>
    from airflow.contrib.operators.ecs_operator import EcsOperator
ImportError: cannot import name 'EcsOperator' from 'airflow.contrib.operators.ecs_operator' (/usr/local/lib/python3.7/site-packages/airflow/contrib/operators/ecs_operator.py)

What am I doing wrong here?

Solution

  • The correct requirements.txt:

    (empty)

    And the correct import:

    from airflow.providers.amazon.aws.operators.ecs import ECSOperator

    Note the casing!