Een consumer-Dag plannen op een Asset

Nu de sales-producer aangeeft wanneer data klaarstaat, heb je een consumer-Dag nodig die automatisch draait zodra de asset is bijgewerkt. Definieer dezelfde asset (s3://data-lake/sales/daily.csv) en stel het schema van de consumer daarop in, zodat Airflow de Dag na elke update triggert.