Definování pořadí tasků
Teď, když už znáš bitshift syntaxi, je čas definovat pořadí tasků. Máš k dispozici tři tasky: cleanup, consolidate a push_data.
Dekorátory dag a task z airflow.sdk jsou už naimportované.
Toto cvičení je součástí kurzu
Úvod do Apache Airflow v Pythonu
Pokyny k cvičení
- Nastav task
cleanuptak, aby se spustil jako první, před taskemconsolidate– použij bitshift syntaxi. - Nastav
consolidatejako druhý apush_datajako poslední v pořadí.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
@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()