气流：运行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每分钟

回答

相关问题