最近更新了 AirFlow 2.x 版本,发现配置了 schedulr_interval
之后,任务根本无法进行调度。
dag = DAG(
dag_id='test_demo',
default_args=default_args,
start_date=days_ago(1),
description='Repay rate monitor of test owners',
schedule_interval='0 16 * * *',
tags=['monitor'],
)
最后尝试下来,如果 schedule_interval
使用 crontab 形式的话,start_date
不可以使用 days_ago(1)
这种形式,必须使用 datetime(2021, 1, 1, 0, 0)
这种格式。