Визначення порядку задач

Тепер, коли ви ознайомилися із синтаксисом бітового зсуву, час визначити порядок виконання задач. У вас є три вже оголошені задачі: 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()

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