RNHTTR opened a new pull request #14321: URL: https://github.com/apache/airflow/pull/14321
Task instances would not be terminated when dagrun_timeout is exceeded which allowed new DAG runs to be created, but task instances within the new DAGs would never be instantiated. As alluded to in #13407, the query to determine if a DAG is active is based on [task instances being unfinished](https://github.com/apache/airflow/blob/master/airflow/jobs/scheduler_job.py#L1502-L1512). Since task instances were not being set to a `State.finished` state when their DAG run was set to `FAILED` state, the scheduler continued to pick up the DAG as `RUNNING`, and tasks in new DAG runs would never be scheduled. closes: #12912 related: #13407 ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
