Что такое оператор в Airflow

В Airflow оператор — это атомарная задача, выполняющая определенное действие. Операторы определяют, что делать (например, запустить скрипт, отправить email), а не как (это контролируется исполнителями).

Примеры:

• BashOperator — выполняет bash-команду
• PythonOperator — вызывает Python-функцию
• EmailOperator — отправляет email

Код:

from airflow.operators.bash import BashOperator

task = BashOperator(
    task_id="print_date",
    bash_command="date",
    dag=dag
)

Нюансы:

• Операторы должны быть идемпотентными (повторный запуск не ломает систему).
• Не хранят состояние между запусками (для этого используют XCom или внешние системы).
• Наследуются от BaseOperator.