LoslegenKostenlos starten

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?

Diese Übung ist Teil des Kurses

<Kurs>Building Data Pipelines with Airflow</Kurs>
Kurs ansehen

Interaktive praktische Übung

Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis

Übung starten