Airflow:每分钟运行 DAG

Question

您好，我的 DAG 参数结构如下


默认参数 = {
'所有者':' Airflow '，
'depends_on_past':错误，
'开始日期': 日期时间(2017, 9, 26),
'schedule_interval': "* * * * *",
'电子邮件': ['airflow@airflow.com'],
'email_on_failure':错误，
'email_on_retry':错误，
}


但我没有看到我的 Airflow 调度程序每隔一分钟或在任何地方安排这些任务。我也咨询过这个 question 但它似乎不起作用。我在构建 DAG 时是否遗漏了某些内容？

Answer 1

我对此不是 100% 确定(并且刚刚开始深入研究 Airflow 代码来尝试验证)，但您可能需要将计划间隔传递到 DAG 中，如下所示:

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

我曾尝试像你那样做，但也没有成功。尽管我将 0 12 * * * 作为我的计划间隔，但这似乎对我有用。