एक न्यूनतम TaskFlow Dag लिखना

आपकी टीम एक नया डेटा पाइपलाइन प्रोजेक्ट शुरू कर रही है। पूरी पाइपलाइन बनाने से पहले, आपके लीड ने आपसे कहा है कि आप एक न्यूनतम Dag सेट अप करें ताकि यह जाँच हो सके कि environment सही तरह से काम कर रहा है।

एक अभ्यास फ़ाइल के अंत में dag.test() शामिल है, जो पूरे Dag को एक ही प्रोसेस में चलाता है ताकि आप सीधे task का आउटपुट देख सकें।