Search code examples
airflowgoogle-cloud-composer

How do I import Airflow operators for version 2.2.5?

I have just upgraded my Airflow to 2.2.5 and I can't use the EmptyOperator. It should be simple from airflow.operators.empty import EmptyOperatorbut I get the error ModuleNotFoundError: No module named 'airflow.operators.empty'. I also tried:

from airflow.operators import empty
from empty.operators import EmptyOperator

The Airflow repo itself shows the structure that would mean from airflow.operators.empty import EmptyOperator should work but it doesn't so I am really puzzled as to what is going on.

Solution

  • EmptyOperator was released in Airflow 2.3.0.

    In Airflow 2.3.0 DummyOperator was deprecated in favor of EmptyOperator (See PR)

    For Airflow>=2.3.0 you should use EmptyOperator:

    from airflow.operators.empty import EmptyOperator

    For Airflow<2.3.0 you should use DummyOperator:

    from airflow.operators.dummy import DummyOperator