From 3f5280b8c7f20c7f6242c10d347eac849a7aaddd Mon Sep 17 00:00:00 2001 From: Jed Cunningham <66968678+jedcunningham@users.noreply.github.com> Date: Sat, 22 Apr 2023 12:34:14 -0500 Subject: [PATCH] Update log level in scheduler critical section edge case (#30694) This log message can be useful if the scheduler ends up needing to query TIs more than once per scheduler loop, so make it INFO vs DEBUG to increase discoverability. --- airflow/jobs/scheduler_job_runner.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py index 0f750e30c1bb0..2bd9a19dbc49a 100644 --- a/airflow/jobs/scheduler_job_runner.py +++ b/airflow/jobs/scheduler_job_runner.py @@ -598,8 +598,8 @@ def _executable_task_instances_to_queued(self, max_tis: int, session: Session) - if is_done or not found_new_filters: break - self.log.debug( - "Found no task instances to queue on the %s. iteration " + self.log.info( + "Found no task instances to queue on query iteration %s " "but there could be more candidate task instances to check.", loop_count, )