在 Asset 上排程 consumer Dag

既然 sales producer 會在資料就緒時發出訊號，你需要一個 consumer Dag，只要該 asset 有更新就會自動執行。定義相同的 asset（s3://data-lake/sales/daily.csv），並把 consumer 的排程設為該 asset，讓 Airflow 在每次更新後觸發 Dag。