EmpezarEmpieza 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?

Este ejercicio forma parte del curso

Building Data Pipelines with Airflow

Ver curso

ejercicio interactivo práctico

Convierte la teoría en práctica con uno de nuestros ejercicios interactivos

Empezar ejercicio