क्लासिक Dag को TaskFlow में बदलना

आपकी टीम ने सभी नए पाइपलाइनों के लिए TaskFlow API अपनाने का निर्णय लिया है। आपके मैनेजर आपसे कहते हैं कि आप एक मौजूदा ETL पाइपलाइन को फिर से लिखें जो PythonOperator और मैनुअल >> वायरिंग का उपयोग करती थी।

मूल क्लासिक संस्करण संदर्भ के लिए dags/classic_etl.py में उपलब्ध है। एक स्कैफ़ोल्ड किया हुआ TaskFlow संस्करण आपके पूरा करने के लिए तैयार है।