如何在Apache Airflow中删除DAG运行？

Question

我知道有一种方法可以删除DAG。但是是否可以删除具有特定run_id的DAG运行？像这样：

airflow delete_dag_run <dag_id> <run_id>

- Oleg Alexander

---

删除DAG的一种方法是从dags文件夹中删除dag文件。 - bigbounty

https://dev59.com/71kR5IYBdhLWcg3w6ROo - Nitin Pandey

有人知道我如何重新启动意外删除的DAG运行吗？ - Shivangi Singh

Answer 1

在Airflow UI中删除DAG运行：

1. 浏览 > "DAG Runs"。
2. 选择左侧复选框中要删除的DAG运行。
3. "选择操作" > 删除。

- Oleg Alexander

---

我执行了这三个步骤。但是删除的运行在大约1分钟后又重新生成了。 - Smile

Answer 2

您还可以从airflow数据库中删除“DAG运行”：

DELETE FROM dag_run
WHERE dag_id='my_dag_id' AND 
state='STATE_I_WANT_TO_DELETE'

- prayagupa

---

从数据库中删除是否足够，以便Airflow不会从内存/会话/其他地方取出这些运行并执行？ - andilabs

@andilabs 这是一个好问题，我的经验是airflow似乎不断检查数据库，所以我没有看到太多的延迟。对我来说这是有道理的，因为数据库是DAG的最终状态。即使我从airflow控制台UI进行更改，我相信它也会更新数据库。 - prayagupa

任务实例也应该被删除，是吗？ - Bumsik Kim