Airflow 重跑dag中部分失败的任务

Posted zjc10203

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Airflow 重跑dag中部分失败的任务相关的知识,希望对你有一定的参考价值。

重跑dag中部分失败的任务

例如 dagA 中, T1 >> T2 >> T3 >> T4 >> T5  ,其中 T1 T2 成功, T3 失败, T4  T5因为依赖 T3,也不会运行。

跳过 T1   T2  重跑 T3 T4 T5 的方法是:

(1)点击 T3 clear ,默认会clear T4  T5 的状态

(2)返回到上一级,点击 dagA 名字,点击 Recursive 和 Downstream (airflow的界面,看不出来到底有没有选择,反正各点一次,  Uncheck ),然后点击 clear

技术分享图片

 

以上是关于Airflow 重跑dag中部分失败的任务的主要内容,如果未能解决你的问题,请参考以下文章

Airflow 中文文档:UI /截图

如何在 Airflow 上重新启动失败的任务

Airflow DAG - 如何首先检查BQ(必要时删除)然后运行数据流作业?

Apache Manged Airflow EMR 操作员 DAG 失败

Apache Airflow:在单个 DAG 运行中运行所有并行任务

在 DAG 运行期间动态生成 DAG - Airflow