【问题标题】:Airflow: Run DAG every minute气流:每分钟运行一次 DAG
【发布时间】:2017-09-28 01:13:24
【问题描述】:

您好,我的 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 时是否遗漏了什么?

【问题讨论】:

  • 是否启用了 DAG?当您进入 UI 的主页时,每个 DAG 都应该有一个开/关切换。
  • 您的调度程序正在运行吗?您是否浏览了airflow.incubator.apache.org/… 的文档?
  • 是的,调度程序正在运行并且 DAG 已启用。我得到了奇怪的间隔,而不是我预期的每分钟更新

标签: airflow


【解决方案1】:

我对此不是 100% 确定(刚刚开始深入研究气流代码以尝试验证),但您可能需要像这样将调度间隔传递给 DAG:

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

我曾尝试像您那样做,但也没有运气。尽管我将0 12 * * * 作为我的日程安排间隔,但这似乎对我有用。

【讨论】:

猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2022-11-02
  • 1970-01-01
  • 2021-05-03
  • 1970-01-01
相关资源
最近更新 更多