Volgorde van taken definiëren
Nu je de bitshift-syntaxis kent, is het tijd om de taakvolgorde te bepalen. Je hebt drie al gedefinieerde taken: cleanup, consolidate en push_data.
De dag- en task-decorators uit airflow.sdk zijn al geïmporteerd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Stel de taak
cleanupzo in dat deze eerst draait vóór de taakconsolidate, met behulp van de bitshift-syntaxis. - Stel
consolidatein om daarna te draaien enpush_dataals laatste.
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
@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()