Definisci l'ordine dei task
Ora che hai imparato la sintassi bitshift, è il momento di definire l'ordine dei task. Al momento hai tre task definiti: cleanup, consolidate e push_data.
I decorator dag e task da airflow.sdk sono già importati.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Configura il task
cleanupin modo che venga eseguito per primo, prima del taskconsolidate, usando la sintassi bitshift. - Configura
consolidateper essere eseguito dopo e il taskpush_dataper essere eseguito per ultimo.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
@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()