Get startedGet started for free

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:

  1. In the Dags view, find both sales_producer and sales_consumer and activate them using the toggle switch.
  2. Trigger sales_producer by clicking the play icon, selecting Single Run, then Trigger.
  3. Wait for the producer run to complete (all tasks green).
  4. Check whether sales_consumer was triggered automatically without you clicking anything.

After the sales_producer run completes, what happens to sales_consumer?

This exercise is part of the course

Building Data Pipelines with Airflow

View Course

Hands-on interactive exercise

Turn theory into action with one of our interactive exercises

Start Exercise