如何重新啓動氣流

Question

失敗的任務我使用的是LocalExecutor和我的DAG有3任務其中任務（C）是依賴於任務（A）。任務（B）和任務（A）可以並行像運行下面

A - >ç

乙

所以任務（A）失敗和，但任務（B）跑得很好。任務（C）在任​​務（A）失敗時尚未運行。

我的問題是我該如何重新運行任務（A），因此任務（C）運行一旦任務（A）完成並且Airflow UI將其標記爲成功。

Answer 1

在UI：

1. 轉到DAG，並且要更改
2. 點擊GraphView
3. 點擊任務A
4. 點擊 「清除」
運行的DAG運行

這將讓任務A再次運行，如果成功，任務C應該運行。 這是有效的，因爲當你清除一個任務的狀態時，調度程序會將它視爲它之前沒有運行過這個DAG運行。