Clearing a dag in the running state leads to tasks getting stuck in restarting, and emit heartbeat timeout events continuously.

[jessicaschueler]

Apache Airflow version

3.0.5

If "Other Airflow 2 version" selected, which one?

No response

What happened?

When a dag is cleared while in the running state, the tasks will get stuck in the restarting state. They will then emit heartbeat timeout events continuously, and the dag will remain in the running state until manually marked as failed/success.

What you think should happen instead?

When a dag in the running state is cleared, all tasks should proceed from restarting to up_for_retry.

How to reproduce

In any dag on Airflow 3, clear the dag while in the running state.

Operating System

macOS Sequia 15.6.1

Versions of Apache Airflow Providers

No response

Deployment

Astronomer

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[rawwar]

Tested on main branch and this issue exists on main. I used CeleryExecutor.

[rawwar]

Tested this on 3.0.0 as well, and the issue exists. So, not a regression.