Pianificare un Dag consumer su un Asset

Ora che il producer delle vendite segnala quando i dati sono pronti, ti serve un Dag consumer che venga eseguito automaticamente ogni volta che l'asset viene aggiornato. Definisci lo stesso asset (s3://data-lake/sales/daily.csv) e imposta la pianificazione del consumer su di esso, così Airflow attiverà il Dag dopo ogni aggiornamento.