How to automaticlly rerun the zombie tasks

[linhgao]

Description

My airflow cluster is deployed on the k8s cluster, when the worker container is restarted, the long-run jobs will failed.
And now I only rerun manually, if I don't rerun in time, it will affect the normal operation of workflow.

So, I want to achieve the feature that the airflow scheduler can automaticlly rerun the zombie tasks.

Use case/motivation

When the scheduler find the zombie tasks, we can choose by the airflow configuration that mark failed these tasks or automaticlly add these task into queue.

Related issues

no

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

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

[boring-cyborg]

Thanks for opening your first issue here! Be sure to follow the issue template!