Mulai sekarangMulai 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?

Latihan ini merupakan bagian dari kursus

Building Data Pipelines with Airflow

Lihat Kursus

Latihan interaktif langsung

Ubah teori menjadi aksi dengan salah satu latihan interaktif kami

Mulai latihan