वायु प्रवाह "यह DAG नहीं है वेबसर्वर DagBag वस्तु में उपलब्ध"

Question

जब मैं dags फ़ोल्डर में एक नया DAG अजगर स्क्रिप्ट डाल, मैं DAG यूआई में DAG की एक नई प्रविष्टि देख सकते हैं, लेकिन यह स्वचालित रूप से सक्षम नहीं किया गया। उस पर, ऐसा लगता है कि ठीक से भी लोड नहीं होता है। मैं सूची के दाईं ओर केवल कुछ बार ताज़ा बटन पर क्लिक कर सकता हूं और डीएजी को शेड्यूल करने में सक्षम होने के लिए सूची के बाईं ओर चालू/बंद बटन टॉगल कर सकता हूं। ये मैन्युअल प्रक्रिया हैं क्योंकि मुझे कुछ ट्रिगर करने की आवश्यकता है, भले ही डीएजी स्क्रिप्ट को डैग फ़ोल्डर के अंदर रखा गया हो।

कोई भी इस पर मेरी सहायता कर सकता है? क्या मुझे कुछ याद आया? या यह एयरफ्लो में एक सही व्यवहार है?

वैसे, जैसा कि पोस्ट शीर्षक में उल्लिखित है, इस संदेश के साथ एक संकेतक है "यह डीएजी वेबसर्वर डैगबैग ऑब्जेक्ट में उपलब्ध नहीं है। यह इस सूची में दिखाई देता है क्योंकि शेड्यूलर ने इसे सक्रिय के रूप में चिह्नित किया है मेटाडेटा डेटाबेस "मैं इस मैनुअल प्रक्रिया को ट्रिगर करने से पहले डीएजी शीर्षक के साथ टैग किया गया।

Answer 1

मुद्दा क्योंकि डिफ़ॉल्ट रूप से DAG में DagBag में डाल दिया जाता है राज्य रुका हुआ है ताकि अनुसूचक आरंभ/पुनः आरंभ करने पर बैकफ़िल गतिविधि के बहुत सारे के साथ अभिभूत नहीं है।

इस परिवर्तन के चारों ओर अपने airflow.cfg फ़ाइल में नीचे सेटिंग काम करने के लिए:

# Are DAGs paused by default at creation 
dags_are_paused_at_creation = False 

आशा इस मदद करता है। चीयर्स!

Answer 2

यह आप नहीं है और न ही यह सही या अपेक्षित व्यवहार है। यह एयरफ्लो के साथ एक वर्तमान 'बग' है। वेब सर्वर डैगबैग को इस तरह से कैश कर रहा है कि आप इसे वास्तव में अपेक्षित रूप से उपयोग नहीं कर सकते हैं।

क्या दिमित्री अपनी टिप्पणी में सुझाव देता है कि अब आप क्या कर सकते हैं मुझे डर है। उसके बाद आप (गैर) -इस्यू के साथ समाप्त हो सकते हैं कि प्रियंका अंक, लेकिन यह आपके इंस्टॉलेशन में आपके द्वारा कॉन्फ़िगरेशन के आधार पर व्यवहार (राज्य: रुका हुआ या नहीं) अपेक्षित है।

आधिकारिक TODO से रोडमैप के हिस्से के रूप:

• प्रयास वेब सर्वर के लिए DagBag कैशिंग को हटाने के वायु प्रवाह वेब सर्वर को पुनः आरंभ करने