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

【问题标题】：How to delete a DAG run in Apache Airflow?如何删除在 Apache Airflow 中运行的 DAG？
【发布时间】：2021-12-28 14:27:37
【问题描述】：

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

airflow delete_dag_run <dag_id> <run_id>

【问题讨论】：

标签： airflow

【解决方案1】：

从 Airflow UI 中删除 DAG Run：

【讨论】：

【解决方案2】：

您也可以从气流数据库中删除“DAG Runs”：

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

【讨论】：

正在从数据库中删除足够多的内容，因此气流不会以某种方式将其从内存/会话中耗尽并执行？
@andilabs 这是一个好问题，我的经验是气流似乎不断检查数据库，所以我没有看到太多延迟。这对我来说很有意义，因为数据库是 DAG 的最终状态。即使我从气流控制台 UI 更改，我相信它也会更新数据库。
不应该把任务实例也删掉吗？