示例DAG無限期地陷入「運行」狀態

在我第一次進入氣流時，我試圖運行安裝時附帶的示例DAGS之一。這是v.1.8.0。下面是我的步驟：示例DAG無限期地陷入「運行」狀態

$ 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分鐘到現在），雖然從這項任務的快速檢查應採取幾秒鐘的事。我如何解決這個問題？我怎樣才能看到它卡在哪一步？

來源

2017-04-19 gcbenison

你可以分享你的代碼嗎？如果我們知道你在做什麼，它會更容易回答 –

我沒有添加超過v.1.8.0安裝提供的任何代碼。 – gcbenison

哦！檢查schedule_interval和start_date，如果日期和時間安排在將來，腳本只會在特定的日期和時間觸發 –

要運行任何的DAG，你需要確保兩個進程正在運行：

airflow webserver
airflow scheduler

如果你只有airflow webserver運行，用戶界面將顯示的DAG爲running ，但是如果您單擊DAG，則它的任何任務都不是running或scheduled，而是Null狀態。這意味着他們正在等待被airflow scheduler接收。如果airflow scheduler未運行，您將永遠處於此狀態，因爲這些任務從未被執行。

來源

2018-01-16 18:11:26

不知道爲什麼這個答案downvoted，但這實際上工作。謝謝！ –

示例DAG無限期地陷入「運行」狀態

回答

相關問題