最近更新了 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) 这种格式。
版权声明
本站仅做备份收录,仅供研究与教学参考之用。
读者将信息用于其他用途的,全部法律及连带责任由读者自行承担,本站不承担任何责任。









评论