氣流：運行DAG每分鐘

您好我有我的DAG參數構造爲使氣流：運行DAG每分鐘

default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start_date': datetime(2017, 9, 26), 'schedule_interval': "* * * * *", 'email': ['[email protected]'], 'email_on_failure': False, 'email_on_retry': False, }

但我沒有看到我的氣流調度調度這些任務，一分鐘間隔或任何地方都沒有。我也諮詢了這個question，但它似乎沒有工作。我在構建DAG時錯過了些什麼？

來源

2017-09-28 Minh Mai

DAG是否啓用？當您進入用戶界面的主頁面時，每個DAG應該有一個開/關切換。 –

您的調度程序是否正在運行？您是否瀏覽了https://airflow.incubator.apache.org/faq.html#why-isn-t-my-task-getting-scheduled上的文檔？ –

是調度程序正在運行並且DAG已啓用。我越來越奇怪的時間間隔，而不是像我預期的每分鐘更新 –

我不是100％確定這（剛開始挖進氣流代碼嘗試和驗證），但您可能需要安排時距傳遞到DAG像這樣：

dag = DAG(DAG_NAME, schedule_interval='* * * * *', default_args=default_args)

我試圖像你這樣做，也沒有運氣。這似乎適用於我，雖然我有0 12 * * *作爲我的日程安排間隔。

來源

2017-09-28 13:16:56 Mike

啊是的，應該是這樣。我已經在https://stackoverflow.com/a/46183148/1969152中解釋過，但仍然錯過了！ –

氣流：運行DAG每分鐘

回答

相關問題