如何在 Airflow 上重启失败的任务并保留失败记录?

How to restart a failed task on Airflow and keep the failure record?

我的 DAG 看起来像这样:

任务 1 >> 任务 2 >> 任务 3

任务 2 失败了。 我想从最后一个故障点 task2 重新启动 dagrun,我知道我可以为此使用 "clear"。

问题是当我使用 clear 时,执行尝试被清除,回头看我再也没有这次失败的记录了。

我想知道我是否可以重新运行,但仍然保留失败历史。

故障数据在日志内的选项卡中可用。

例如,如果我将自动重试设置为 3 并且所有 3 次都失败,Airflow UI 日志中将有 3 个选项卡。

同样,重新启动失败的任务会在新选项卡中记录新的运行。

它将在 "Log by attempts" 的标题下。

当然这也意味着您可以在实际的日志文件中查看它们。日志文件中有尝试编号以指示尝试之间的间隔。