Kunal8954 opened a new pull request, #72403: URL: https://github.com/apache/airflow/pull/72403
Closes #72387 Currently, when a DAG reaches its max_active_runs limit, the scheduler sets DagModel.exceeds_max_non_backfill without logging anything, so operators have no way to tell which DagRun/TaskInstance is occupying the active slots from the scheduler logs alone. This adds a targeted, one-time log in SchedulerJobRunner._set_exceeds_max_active_runs: the moment a DAG newly reaches (or exceeds) max_active_runs, it queries the blocking run_ids and the task_ids/states holding them, and logs that context. The query only runs on the False->True transition, so there is no added database load during normal, healthy scheduling loops, and no repeated log spam while the DAG stays stuck. Adds two unit tests covering the log content and the no-repeat-log behavior on a subsequent call. -- 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]
