Seeing asset-based scheduling in action
Both the sales_producer and sales_consumer Dags from the previous exercises have been loaded into the Airflow UI. The producer writes sales data and updates the s3://data-lake/sales/daily.csv asset. The consumer is scheduled on that asset.
Follow these steps:
- In the Dags view, find both
sales_producerandsales_consumerand activate them using the toggle switch. - Trigger
sales_producerby clicking the play icon, selecting Single Run, then Trigger. - Wait for the producer run to complete (all tasks green).
- Check whether
sales_consumerwas triggered automatically without you clicking anything.
After the sales_producer run completes, what happens to sales_consumer?
Este ejercicio forma parte del curso
Building Data Pipelines with Airflow
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio