Airflow DAG调度月底任务

6

我想在Airflow(v1.9.0)上运行一个调度任务。
我的DAG需要每月末运行,但我不知道如何设置。

my_dag = DAG(dag_id=DAG_ID,
             catchup=False,
             default_args=default_args,
             schedule_interval='30 0 31 * *',
             start_date=datetime(2019, 7, 1))

但这种方法在没有31号的月份无法使用,对吧?
我该如何编写一个schedule_interval以在每个月的月底运行?

1个回答

13

您可以通过在 schedule_interval cron表达式的月份位置上放置 L 来实现此操作。

schedule_interval='59 23 L * *' # 23:59 on the last day of the month

它能工作,但为什么呢? 我在Airflow文档中没有看到。 - Gilmar Vaz
@GilmarVaz 这是cron语法 - Yixing Liu

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接