毎日 3:00 に実行されている DAG があり、過去数週間は問題なく実行されていました。
日付を 7:00 に実行するように更新しましたが、どうやら過去 2 日間は実行されていませんでした。この 2 日間のタスクはステータスが「実行中」(緑色) で表示されますが、コマンドはトリガーされません。
DAG の実行時間を変更するには、さらに何かをする必要がありますか?
過去にこれを解決する 1 つの方法は、この DAG のタスクをメタデータベースでクリーンアップし、start_date を更新することでしたが、これを再度行うことは避けたいと思います。
誰にも提案がありますか？
DAG をスケジュールするために、Airflow は最後のものを探してexecution dateを合計しschedule intervalます。この時間が経過すると、dag が実行されます。開始日を単純に更新することはできません。これを行う簡単な方法は、 と を編集しstart date、schedule intervaldag の名前を変更して (例: xxxx_v2.py)、再デプロイすることです。
execution_dateDAG の名前を変更する別の解決策は、データベース内の DAG の以前のすべてのタスク インスタンスと DAG 実行を編集することです。変更するテーブルはそれぞれtask_instanceとdag_runです。
このアプローチの欠点の 1 つは、Web サーバーを介して完了したタスクのログを参照できなくなることです。