最近更新了 AirFlow 2.x 版本,发现配置了 schedulr_interval 之后,任务根本无法进行调度。

    1. dag = DAG(
    2. dag_id='test_demo',
    3. default_args=default_args,
    4. start_date=days_ago(1),
    5. description='Repay rate monitor of test owners',
    6. schedule_interval='0 16 * * *',
    7. tags=['monitor'],
    8. )

    最后尝试下来,如果 schedule_interval 使用 crontab 形式的话,start_date 不可以使用 days_ago(1) 这种形式,必须使用 datetime(2021, 1, 1, 0, 0) 这种格式。