气流：运行 DAG 每分钟
Airflow: Run DAG every minute
嗨，我的 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 调度程序每隔一分钟或任何地方安排这些任务。我也咨询过这个 question 但它似乎并没有很好地工作。我在构造 DAG 时是否遗漏了什么？
我对此不是 100% 确定（并且刚刚开始深入研究气流代码以尝试验证）但您可能需要像这样将计划间隔传递到 DAG：
dag = DAG(DAG_NAME, schedule_interval='* * * * *', default_args=default_args)
我试过像你那样做，但也没成功。这似乎对我有用，尽管我将 0 12 * * * 作为我的计划间隔。
嗨，我的 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 调度程序每隔一分钟或任何地方安排这些任务。我也咨询过这个 question 但它似乎并没有很好地工作。我在构造 DAG 时是否遗漏了什么？
我对此不是 100% 确定（并且刚刚开始深入研究气流代码以尝试验证）但您可能需要像这样将计划间隔传递到 DAG：
dag = DAG(DAG_NAME, schedule_interval='* * * * *', default_args=default_args)
我试过像你那样做，但也没成功。这似乎对我有用，尽管我将 0 12 * * * 作为我的计划间隔。