Aan de slagBegin gratis

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?

Deze oefening maakt deel uit van de cursus

Building Data Pipelines with Airflow

Bekijk cursus

Interactieve oefening met praktijkervaring

Zet theorie om in actie met een van onze interactieve oefeningen

Begin oefening