DB のシャットダウンが原因で、多くのステップを含む DAG の 1 つが途中で停止しました。DAG を中断したところから開始したいのですが、できることは、DAG の個々のタスクを 1 つずつ開始することだけです。既に完了したタスクの成功に基づいて、中断したところから DAG を開始するように Airflow に指示する方法はありますか?
最初のタスクの 1 つが終了し、残りがキューに入れられているか、ステータスがないサンプルを次に示します。
個々のタスク ( runme_1) をクリックすると、再起動できます。
ただし、依存関係が満たされていないタスク ( などrun_after_loop) を開始しようとすると、次のエラー メッセージが表示さ
れます。
任意のタスクをクリックしてキューに入れ、すべての依存関係を正しい順序で実行できるようにしたいと考えています。それは可能ですか？
Airflow 1.9.0 を実行しています。