Definiowanie kolejności zadań
Skoro już wiesz, jak działa składnia bitshift, czas zdefiniować kolejność wykonywania zadań. Masz do dyspozycji trzy zdefiniowane zadania: cleanup, consolidate oraz push_data.
Dekoratory dag i task z biblioteki airflow.sdk są już zaimportowane.
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Instrukcje do ćwiczenia
- Skonfiguruj zadanie
cleanuptak, aby uruchamiało się przed zadaniemconsolidate, używając składni bitshift. - Skonfiguruj
consolidatejako kolejne zadanie, apush_datajako ostatnie.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
@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()