airflow - 如何在 Airflow 上重新启动失败的任务并保留失败记录？
问题描述
我的 DAG 如下所示：
任务1 >> 任务2 >> 任务3
task2 失败了。我想从最后一个故障点 task2 重新启动 dagrun，我知道我可以为此使用“clear”。
问题是，当我使用 clear 时，执行尝试被清除并且回头看我不再有这个失败的记录。
我想知道是否可以重新运行，但仍保留失败历史记录。
解决方案
故障数据在日志内的选项卡中可用。
例如，如果我将自动重试次数设置为 3 并且所有 3 次都失败，则 Airflow UI 日志中将有 3 个选项卡。
同样，重新启动失败的任务会将新的运行记录在新选项卡中。
它将在“尝试记录”的标题下。
当然这也意味着您可以在实际的日志文件中查看它们。日志文件中有一个尝试编号，以指示尝试之间的划分。