उदाहरण डीएजी "चलने" राज्य में अनिश्चित काल तक फंस जाता है

Question

एयरफ्लो में अपने पहले प्रयास में, मैं इंस्टॉलेशन के साथ आने वाले उदाहरणों में से एक को चलाने की कोशिश कर रहा हूं। यह v.1.8.0 है। यहाँ मेरी कदम हैं:

$ airflow trigger_dag example_bash_operator 
[2017-04-19 15:32:38,391] {__init__.py:57} INFO - Using executor SequentialExecutor 
[2017-04-19 15:32:38,676] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software/kludge/airflow/dags 
[2017-04-19 15:32:38,947] {cli.py:185} INFO - Created <DagRun example_bash_operator @ 2017-04-19 15:32:38: manual__2017-04-19T15:32:38, externally triggered: True> 
$ airflow dag_state example_bash_operator '2017-04-19 15:32:38' 
[2017-04-19 15:33:12,918] {__init__.py:57} INFO - Using executor SequentialExecutor 
[2017-04-19 15:33:13,229] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software/kludge/airflow/dags 
running 

डेग राज्य एक लंबे समय के लिए "चल" बनी हुई है (कम से कम 20 मिनट के अब तक), हालांकि इस कार्य की एक त्वरित निरीक्षण से यह सेकंड के एक मामले में लेना चाहिए। मैं इसका निवारण कैसे कर सकता हूं? मैं कैसे देख सकता हूं कि यह किस चरण पर फंस गया है?

Answer 1

किसी भी DAGs चलाने के लिए आपको दो प्रक्रियाओं चल रहे हैं सुनिश्चित करने की आवश्यकता:

• airflow webserver
• airflow scheduler

आप केवल airflow webserver चला रहे हैं, यूआई running रूप DAGs दिखाएगा , लेकिन यदि आप डीएजी पर क्लिक करते हैं, तो इसका कोई भी कार्य वास्तव में running या scheduled नहीं है, बल्कि Null राज्य में है। इसका क्या अर्थ है कि वे airflow scheduler द्वारा उठाए जाने की प्रतीक्षा कर रहे हैं। यदि airflow scheduler नहीं चल रहा है, तो आप इस स्थिति में हमेशा के लिए फंस जाएंगे, क्योंकि कार्य निष्पादन के लिए कभी नहीं उठाए जाते हैं।