Lets say scheduler is stopped for 5 hours and I had dag scheduled for twice every hour. Now when I restart the scheduler I do not want to airflow to backfill all the instances those were missed, Instead I want it to continue from the current hour.
问问题
1839 次
2 回答
2
要实现此行为，您可以使用LatestOnlyOperator最近引入到 master的 ，到 DAG 的开头。虽然它目前不是已发布版本的一部分（1.7.1.3 是撰写本文时的最新版本）。
于 2016-11-13T20:54:09.447 回答
1
我确定您不再等待答案，但作为参考，请参见此处：https ://cwiki.apache.org/confluence/display/AIRFLOW/Common+Pitfalls 。
“当需要更改您的 start_date 和计划间隔时，请更改 dag（又名 dag_id）的名称 - 我遵循约定：my_dag_v1、my_dag_v2、my_dag_v3、my_dag_v4 等......”
于 2016-05-21T12:24:30.703 回答