This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 3f5280b8c7 Update log level in scheduler critical section edge case
(#30694)
3f5280b8c7 is described below
commit 3f5280b8c7f20c7f6242c10d347eac849a7aaddd
Author: Jed Cunningham <[email protected]>
AuthorDate: Sat Apr 22 12:34:14 2023 -0500
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 0f750e30c1..2bd9a19dbc 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -598,8 +598,8 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
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,
)
