変更されたエアフローダグを別の開始時刻から配置するにはどうすればよいですか？

Question

スケジューラが5時間停止していて、毎時2回のダグを予定していたとします。スケジューラを再起動すると、私は気付かれずに失われたすべてのインスタンスをバックフィルしたいのではなく、現在の時間から続行したいと思っています。

Answer 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などを..."

Answer 2

この動作を実現するには、LatestOnlyOperator（最近はintroduced to master）をDAGの先頭に使用できます。これは現在、リリースされたバージョンの一部ではありません（1.7.1.3はこの記事の執筆時点での最新バージョンです）。