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?
Это упражнение является частью курса
Building Data Pipelines with Airflow
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение