Señalar disponibilidad de datos con una salida Asset

Tu equipo tiene un pipeline que escribe los datos de ventas diarios en s3://data-lake/sales/daily.csv, y varios pipelines posteriores dependen de él. En lugar de hacer que consulten con un temporizador o adivinen cuándo está listo el archivo, vas a adjuntar una salida Asset para que esta tarea señale que los datos se actualizaron en cuanto termine. Esa señal es lo que permite que otros Dags se programen en función de los propios datos.

Después de completar el código, ejecuta el archivo y luego verifica que el asset se haya registrado y actualizado usando la CLI de Airflow.