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.

(cherry picked from commit 3f5280b)
  • Loading branch information
jedcunningham authored and ephraimbuddy committed Apr 23, 2023
1 parent b11fc14 commit 1e7e883
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 1e7e883

Please sign in to comment.