Skip to content

Commit

Permalink
Update log level in scheduler critical section edge case (#30694)
Browse files Browse the repository at this point in the history
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.
  • Loading branch information
jedcunningham authored Apr 22, 2023
1 parent b5296b7 commit 3f5280b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions airflow/jobs/scheduler_job_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down

0 comments on commit 3f5280b

Please sign in to comment.