Definiera uppgifternas ordning

Nu när du har lärt dig om bitshift-syntaxen är det dags att definiera i vilken ordning uppgifterna ska köras. Du har tre definierade uppgifter: cleanup, consolidate och push_data.

Dekoratorerna dag och task från airflow.sdk är redan importerade.

Den här övningen är en del av kursen

Introduktion till Apache Airflow i Python

Visa kurs

Övningsinstruktioner

Konfigurera uppgiften cleanup så att den körs först, före consolidate, med hjälp av bitshift-syntaxen.
Konfigurera consolidate att köras därefter och push_data att köras sist.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

@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()

Redigera och kör kod