Airflow如何批量清除所有失败运行实例并重新执行？

GUI操作方式（适合少量实例或可视化操作） #

• 打开Airflow GUI，进入目标DAG的详情页面
• 切换到「Tree」或「Graph」视图，通过状态筛选器只显示失败的任务实例，然后勾选需要处理的所有实例（支持全选）
• 点击页面顶部的「Actions」下拉菜单，选择「Clear」选项
• 在弹窗中确认清除范围（建议勾选「Only failed」避免误操作），确认后完成清除。调度器会自动重新触发这些任务运行

命令行操作方式（适合大量实例，效率更高） #

使用Airflow CLI的clear命令可以批量清理指定范围的失败任务：

1. 清理整个DAG在指定日期范围内的失败实例：

airflow dags clear -d <你的DAG_ID> -s 2024-01-01 -e 2024-01-31 --only-failed

2. 清理DAG中特定任务的失败实例：

airflow tasks clear -d <你的DAG_ID> -t <目标TASK_ID> -s 2024-01-01 -e 2024-01-31 --only-failed

参数说明：

• -d：指定目标DAG的ID
• -t：指定需要清理的任务ID（仅tasks clear命令可用）
• -s/-e：分别指定任务实例的开始、结束日期
• --only-failed：仅处理失败状态的任务，避免干扰正常运行的任务

注意事项 #

• 务必先修复Python模块导入的问题，否则重试后任务仍会失败
• 清除操作会删除任务的现有运行记录，调度器会按照DAG的调度规则重新触发任务

内容的提问来源于stack exchange，提问作者extremeaxe5