Programarea unui DAG consumator pe un Asset

Acum că DAG-ul producător de vânzări semnalează când datele sunt pregătite, ai nevoie de un DAG consumator care să ruleze automat ori de câte ori asset-ul este actualizat. Definește același asset (s3://data-lake/sales/daily.csv) și setează planificarea consumatorului pe acesta, astfel încât Airflow să declanșeze DAG-ul după fiecare actualizare.