Airflow：每分钟运行DAG

Question

Airflow：每分钟运行DAG

4

你好，我把我的DAG参数组织成如下结构：

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

但是我没有看到我的Airflow调度程序按一分钟或任何时间间隔安排这些任务。我还参考了这个问题，但它似乎也不起作用。在构建我的DAG时，我是否遗漏了什么？

- Minh

DAG是否已启用？当您进入UI的主页面时，每个DAG旁应该有一个开关按钮。 - Daniel Huang

1

你的调度器在运行吗？你是否查看了 https://airflow.incubator.apache.org/faq.html#why-isn-t-my-task-getting-scheduled 的文档？ - Matthijs Brouns

是的，调度程序正在运行并启用了DAG。我得到了奇怪的间隔，而不是我预期的每分钟更新。 - Minh

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Mike · Accepted Answer

我不是100%确定这一点（刚开始深入研究Airflow代码以尝试验证），但您可能需要将调度间隔传递到DAG中，如下所示：

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

我尝试按照你的方式去做，但是也没有成功。但是似乎这种方式对我有用，我的计划间隔是0 12 * * *。