Schemalägg en konsument-DAG på en Asset

Nu när försäljningsproducenten signalerar att data är redo behöver du en konsument-DAG som körs automatiskt varje gång tillgången uppdateras. Definiera samma tillgång (s3://data-lake/sales/daily.csv) och sätt konsumentens schema till den, så att Airflow triggar DAG:en efter varje uppdatering.