如何在气流中运行cron计划DAG,使其在一个月的第一天运行10:30 cst,在一个月中的其他日子运行10 cst?我



就像我在cron guru中尝试了多种组合,但没有找到任何可能的解决方案。

我有这两个表达式来组合

30 10 1**

10 12 2-31**

您不能在一个cron表达式中实现这一点,您有两个选项:

  1. easy-one:创建dag的两个副本,每个副本都有自己的cron表达式
  2. 困难的一点是:创建一个时间表并将其注册到Airflow插件中,然后可以将其作为timetable参数而不是schedule_interval参数传递给dag
    在此时间表中,您可以实现两种方法:
    • next_dagrun_info:调度器使用它来学习时间表的常规时间表
    • infer_manual_data_interval:当手动触发DAG运行时(例如,从web UI(,调度程序使用此方法来了解如何反向推断超出计划的运行的数据间隔(不是强制性的(

相关内容

  • 没有找到相关文章

最新更新