expand के साथ कई endpoints प्रोसेस करना

आपकी टीम समय के साथ बदलने वाले कई API endpoints से डेटा खींचती है, और हर endpoint के लिए अलग टास्क हार्डकोड करने का मतलब है कि जैसे ही कोई endpoint जोड़ा या हटाया जाता है, Dag को एडिट करना पड़ता है। इस अभ्यास में, आप उस कठोर पाइपलाइन को डेटा-ड्रिवन पाइपलाइन में बदलेंगे: expand() के साथ, Airflow रनटाइम पर endpoints की सूची पढ़ता है और हर आइटम के लिए एक टास्क इंस्टेंस स्पिन-अप करता है, ताकि endpoints की संख्या बदलने पर पाइपलाइन अपने-आप एडजस्ट हो जाए।