How to delete a DAG run in Apache Airflow?

Question

I know there is a way to delete a DAG. But is it possible to delete a DAG run with a specific run_id? Something like:

airflow delete_dag_run <dag_id> <run_id>

One way to delete a DAG is to delete the dag file from the dags folder — bigbounty, Oct 20 '19 at 17:01
https://stackoverflow.com/questions/40651783/airflow-how-to-delete-a-dag — Nitin Pandey, Oct 23 '19 at 04:33
Anyone know how I can restart my accidentally deleted dag run — Shivangi Singh, Apr 30 '21 at 15:06

score 38 · Answer 1 · edited Oct 05 '20 at 19:29

38

To delete a DAG Run from the Airflow UI:

edited Oct 05 '20 at 19:29

prayagupa

answered Oct 22 '19 at 18:34

Oleg Alexander

I performed these 3 steps. But the deleted run spawned again after about 1 minute.. – Smile Aug 31 '23 at 22:20

score 7 · Answer 2 · answered Oct 05 '20 at 19:50

7

You can also delete the "DAG Runs" from airflow database:

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

answered Oct 05 '20 at 19:50

prayagupa

is removing from db enought so airflow won't somehow take this runs out from memory/session whatever and execute? – andilabs May 06 '21 at 12:18
1

@andilabs Thats a good question, my experience was airflow seemed to constantly check database so i did not see much delay there. Which makes sense to me because database is the final state of DAGs. And even if I change from airflow console UI I'm sure it will also update the database. – prayagupa May 06 '21 at 23:10
Shouldn't the task instances be deleted too? – Bumsik Kim Dec 28 '21 at 06:28

2 Answers2