scheduled-tasks - 如何在 Airflow 中运行，以便任务重新运行并继续下游任务

Question

我在 Airflow 中设置了一个工作流程，其中一项工作失败了，在我解决问题后，我想重新运行失败的任务并继续工作流程。详细信息如下:

如上所述，我准备运行任务“20_validation”，我按下了“运行”按钮，如下所示:

但问题是当任务“20_validation”完成时，这些下游任务并没有继续启动。我该怎么办？

Answer 1

使用您在屏幕截图中画出方框的 run 按钮正下方的 clear 按钮。

这将清除失败的任务状态和之后的所有任务(因为下游选择了右侧)，使它们全部运行/重新运行。

由于上游任务失败，下游任务无论如何都不应该运行，所以它不应该导致成功的任务重新运行。