Asset-आधारित scheduling को क्रिया में देखें

पिछले अभ्यासों के sales_producer और sales_consumer दोनों Dags Airflow UI में लोड कर दिए गए हैं. Producer सेल्स डेटा लिखता है और s3://data-lake/sales/daily.csv asset को अपडेट करता है. Consumer उसी asset पर scheduled है.

इन चरणों का पालन करें:

1. Dags view में sales_producer और sales_consumer दोनों को ढूँढें और toggle switch का उपयोग करके सक्रिय करें.
2. play आइकन पर क्लिक करके sales_producer को ट्रिगर करें, Single Run चुनें, फिर Trigger.
3. Producer run पूरा होने की प्रतीक्षा करें (सभी tasks हरे).
4. जाँचें कि क्या sales_consumer अपने आप ट्रिगर हुआ, बिना आपके कुछ क्लिक किए.

---

sales_producer का run पूरा होने के बाद, sales_consumer के साथ क्या होता है?