airflow

    5गर्मी

    1उत्तर

    मैंने खुद को एक ऐसी स्थिति में पाया है जहां मैं मैन्युअल रूप से एक डीएजी रन (airflow trigger_dag datablocks_dag के माध्यम से) चलाता हूं, और डैग रन इंटरफ़ेस में दिखाई देता है, लेकिन फिर यह वास्तव में क

    6गर्मी

    1उत्तर

    के बाद असफल होने के रूप में चिह्नित सबफैग में लंबे समय तक चलने वाला कार्य मेरे पास एक लंबे समय से चलने वाले चरण (आमतौर पर लगभग 2 घंटे के साथ एयरफ्लो में एक सबडैग है, हालांकि यह किस इकाई पर चल रहा है)

    5गर्मी

    2उत्तर

    मैं यूटीसी + 4 टाइमज़ोन में हूं, इसलिए जब एयरफ्लो रात के ईटीएल को ट्रिगर करता है, तो यह पहले से ही 4:00 बजे है। मैं एयरफ्लो को पहले दिन डीएस -1 पर 20:00 बजे दिन पहले डीएस के लिए ट्रिगर करने के लिए कैस

    5गर्मी

    1उत्तर

    एयरफ्लो में, मुझे इस मुद्दे का सामना करना पड़ रहा है कि मुझे job_flow_id को मेरे एमआर-चरणों में से एक को पास करने की आवश्यकता है। मैं ऑपरेटर से job_flow_id पुनर्प्राप्त करने में सक्षम हूं लेकिन जब मैं

    6गर्मी

    1उत्तर

    मैं समझने के लिए संघर्ष कर रहा हूं कि एयरफ्लो में ब्रांचपीथनऑपरेटर कैसे काम करता है। मुझे पता है कि इसका मुख्य रूप से ब्रांचिंग के लिए उपयोग किया जाता है, लेकिन दस्तावेज़ में उलझन में है कि एक कार्य म

    5गर्मी

    1उत्तर

    मैं RabbitMQ दलाल, सेवाओं के साथ वायु प्रवाह कॉन्फ़िगर किया है डिफ़ॉल्ट बात नहीं सुन रहा है। अभी भी कार्यकर्ता को चलाने के लिए कार्य नहीं ले पा - मुझे भी airflow worker -q=default की कोशिश की: अनुसूचक

    8गर्मी

    1उत्तर

    से एयरफ्लो कार्यों को कैसे रोकें/मारें कैसे मैं एयरफ्लो यूआई पर चल रहे कार्य को रोक/मार सकता हूं? मैं LocalExecutor का उपयोग कर रहा हूं। भले ही मैं CeleryExecutor का उपयोग करता हूं, मैं रनिंग कार्य को

    5गर्मी

    1उत्तर

    def mysql_operator_test(): DEFAULT_DATE = datetime(2017, 10, 9) t = MySqlOperator( task_id='basic_mysql', sql="SELECT count(*) from table 1 where id>100;", mysql_conn_id='my

    6गर्मी

    2उत्तर

    क्या आर स्क्रिप्ट को एयरफ्लो डैग के रूप में चलाने के लिए संभव है? मैंने इस पर दस्तावेज के लिए ऑनलाइन देखने की कोशिश की है और ऐसा करने में असमर्थ हूं। धन्यवाद

    10गर्मी

    2उत्तर

    चला रहे हैं मैं एयरफ्लो v1.8.1 का उपयोग कर रहा हूं और कुबेरनेट & डॉकर पर सभी घटकों (कार्यकर्ता, वेब, फूल, शेड्यूलर) चला रहा हूं। मैं Redis के साथ अजवाइन निर्वाहक का उपयोग करें और अपने कार्यों की तरह द