我有一个气流过程,该过程在每个星期日的12:00 am运行。是否有一种方法可以每周精确地在同一时间(绝对时间)触发此过程,而不管先前的运行时间或结果如何。我看到该过程的开始时间一直在蔓延,直到几周后它现在比计划的时间晚了整整16个小时才被触发。我如何使它完全同时启动,而不管先前的运行结果如何,或者先前是否手动触发了(cron之类的行为)?
在DAG的default_args中添加depends_on_past参数,假值将确保在每个间隔内都将创建新的dagrun,而无需依赖于先前的dagrun状态:
'depends_on_past': False
可能没有必要,但是我建议在进行此更改后重新启动调度程序。