Definește ordinea taskurilor

Acum că ai învățat despre sintaxa bitshift, e momentul să definești ordinea taskurilor. Ai trei taskuri definite: cleanup, consolidate și push_data.

Decoratorii dag și task din airflow.sdk sunt deja importați.

Acest exercițiu face parte din cursul

Introducere în Apache Airflow în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Configurează taskul cleanup să ruleze primul, înaintea taskului consolidate, folosind sintaxa bitshift.
Configurează consolidate să ruleze al doilea și taskul push_data să ruleze ultimul.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

Editează și rulează codul