ephraimbuddy opened a new pull request #17643: URL: https://github.com/apache/airflow/pull/17643
If a DAG goes missing while running, the serialized_dag would be deleted almost immediately as well as the DagRun, but the task instances will not be deleted as they are still being used by the executor. These task instances will still exist in the database without DagRun. If the DAG is regenerated again, and rerun, those existing task instances without DagRun would be picked and the task runner will send a SIGTERM on detecting a state change from failed to None. This PR fixes this by removing TIs without Dagrun before executing tasks Related: #10026 --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst#pull-request-guidelines)** for more information. In case of fundamental code change, Airflow Improvement Proposal ([AIP](https://cwiki.apache.org/confluence/display/AIRFLOW/Airflow+Improvements+Proposals)) is needed. In case of a new dependency, check compliance with the [ASF 3rd Party License Policy](https://www.apache.org/legal/resolved.html#category-x). In case of backwards incompatible changes please leave a note in [UPDATING.md](https://github.com/apache/airflow/blob/main/UPDATING.md). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
