diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py index 883cd05d2b81f..4e581e970904f 100644 --- a/airflow/jobs/scheduler_job_runner.py +++ b/airflow/jobs/scheduler_job_runner.py @@ -1139,14 +1139,14 @@ def _run_scheduler_loop(self) -> None: if self.processor_agent: self.processor_agent.heartbeat() - # Heartbeat the scheduler periodically - perform_heartbeat( - job=self.job, heartbeat_callback=self.heartbeat_callback, only_if_necessary=True - ) + # Heartbeat the scheduler periodically + perform_heartbeat( + job=self.job, heartbeat_callback=self.heartbeat_callback, only_if_necessary=True + ) - # Run any pending timed events - next_event = timers.run(blocking=False) - self.log.debug("Next timed event is in %f", next_event) + # Run any pending timed events + next_event = timers.run(blocking=False) + self.log.debug("Next timed event is in %f", next_event) self.log.debug("Ran scheduling loop in %.2f seconds", timer.duration) if span.is_recording():