किसी Asset पर उपभोक्ता Dag को शेड्यूल करना

अब जब सेल्स प्रोड्यूसर यह सिग्नल देता है कि डेटा तैयार है, तो आपको एक कंज़्यूमर Dag चाहिए जो Asset के अपडेट होते ही अपने आप चले। वही asset (s3://data-lake/sales/daily.csv) परिभाषित करें और कंज़्यूमर का शेड्यूल उसी पर सेट करें ताकि Airflow हर अपडेट के बाद Dag को ट्रिगर करे।