Ver la planificación basada en assets en acción

Tanto los Dags sales_producer como sales_consumer de los ejercicios anteriores se han cargado en la interfaz de Airflow. El productor escribe los datos de ventas y actualiza la asset s3://data-lake/sales/daily.csv. El consumidor se programa en función de esa asset.

Sigue estos pasos:

1. En la vista de Dags, busca sales_producer y sales_consumer y actívalos usando el interruptor.
2. Lanza sales_producer haciendo clic en el icono de reproducir, selecciona Single Run y luego Trigger.
3. Espera a que termine la ejecución del productor (todas las tareas en verde).
4. Comprueba si sales_consumer se ha activado automáticamente sin que tú hagas clic en nada.

---

Después de que termine la ejecución de sales_producer, ¿qué le ocurre a sales_consumer?