Yia*_*nis 0 airflow airflow-scheduler
start_date我不明白以前指定一个DAG有什么用。我读过有关追赶和回填的内容,但我仍然不明白。在什么情况下我想指定过去的 start_date ?
对于计划运行,在运行DAG之前airflow scheduler 等待间隔时间段完成。
例如,假设您希望每月运行一次 dag ,并将其安排为0 3 11 * * ,这意味着该月 11 日凌晨 3 点运行您的 dag。
现在,假设您已在2021 年 1 月 10 日部署了 dag ,那么您预计它会在第二天运行。但实际上,气流要到下个月才会触发你的 DAG。2021 年 2 月 11 日。因此,气流将等待大约一个月,然后才会真正触发原定于 2021 年 1 月 11 日运行的 DAG。
在这种情况下,当您部署 DAG 时,您可以将日期指定start_date为2020 年 12 月 10 日,以便当实际日期(2021 年 1 月 11 日)到来时,调度程序将标记为间隔时间段的完成并开始触发 DAG。
如需更多参考,您可以阅读: https: //www.astronomer.io/guides/scheduling-tasks
| 归档时间: |
|
| 查看次数: |
2678 次 |
| 最近记录: |