Определение порядка выполнения задач

Теперь, когда вы освоили синтаксис битового сдвига, пришло время задать порядок выполнения задач. У вас есть три уже определённые задачи: cleanup, consolidate и push_data.

Декораторы dag и task из airflow.sdk уже импортированы.

Это упражнение является частью курса

Введение в Apache Airflow на Python

Посмотреть курс

Инструкции к упражнению

Настройте задачу cleanup так, чтобы она выполнялась первой — перед задачей consolidate, используя синтаксис битового сдвига.
Настройте consolidate так, чтобы она выполнялась следующей, а задача push_data — последней.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

@dag(
    dag_id="analytics_dag",
    start_date=datetime(2026, 3, 1),
)
def analytics_dag():
    # Run cleanup before consolidate
    cleanup() ____ consolidate()
    # Run consolidate before push_data
    ____

analytics_dag()

Редактировать и запускать код