月底的 Airflow DAG 调度

Question

我想要运行 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到运行？

Answer 1

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

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

月底的 Airflow DAG 调度

Airflow DAG Scheduling for end of month

airflow

airflow-scheduler