Nehmen wir an, der Scheduler wurde für 5 Stunden gestoppt und ich hatte dag zweimal pro Stunde geplant. Jetzt, wenn ich den Scheduler neu starte, möchte ich keine Luftströmung, um all die Instanzen, die verpasst wurden, zu füllen. Stattdessen möchte ich, dass es ab der aktuellen Stunde weitergeht.Wie wird der modifizierte Luftstrom dag von einer anderen Startzeit bereitgestellt?
Ich bin sicher, Sie warten nicht mehr auf eine Antwort, aber als Referenz wird dies hier behandelt: https://cwiki.apache.org/confluence/display/AIRFLOW/Common+Pitfalls.
"Wenn benötigen Ihre start_date und Planintervall zu ändern, ändern Sie den Namen des dag (aka dag_id) - Ich folge der Konvention: my_dag_v1, my_dag_v2, my_dag_v3, my_dag_v4, etc ..."
Um dieses Verhalten zu erreichen, können Sie den LatestOnlyOperator, der vor kurzem introduced to master war, zum Start Ihres DAG verwenden. Es ist jedoch derzeit nicht Teil einer veröffentlichten Version (1.7.1.3 ist die neueste Version zum Schreiben dieses Beitrags).
Wenn wir die dag_id ändern, verlieren wir auch die historischen Laufstatistiken. –