如何在Airflow上重新启动失败的任务 [英] How to restart a failed task on Airflow

问题描述

我使用的是 LocalExecutor ，我的任务有 3个任务，其中任务（C）依赖于任务（A）。任务（B）和任务（A）可以并行运行，如下所示：

I am using a LocalExecutor and my dag has 3 tasks where task(C) is dependant on task(A). Task(B) and task(A) can run in parallel something like below

A-> C

B

因此任务（A）失败，但是任务（B）运行正常。任务（C）尚未运行，因为任务（A）失败。

So task(A) has failed and but task(B) ran fine. Task(C) is yet to run as task(A) has failed.

我的问题是我如何单独重新运行任务（A），因此任务（ C）在任务（A）完成并且Airflow UI将其标记为成功后运行。

My question is how do i re run Task(A) alone so Task(C) runs once Task(A) completes and Airflow UI marks them as success.

推荐答案

在UI中：

1. 转到dag，然后运行dag运行要更改的运行


2. 单击GraphView


3. 单击任务A


4. 单击清除

1. Go to the dag, and dag run of the run you want to change
2. Click on GraphView
3. Click on task A
4. Click "Clear"

这将使任务A重新运行，如果成功，则任务C应该运行。
之所以起作用，是因为当您清除任务的状态时，调度程序会将其视为该dag运行之前从未运行过。

This will let task A run again, and if it succeeds, task C should run. This works because when you clear a task's status, the scheduler will treat it as if it hadn't run before for this dag run.

这篇关于如何在Airflow上重新启动失败的任务的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！