From 8e720b86e8e54f0a01c50e8904029ea8c8df6719 Mon Sep 17 00:00:00 2001 From: Jarek Potiuk Date: Mon, 22 Jul 2024 11:54:56 +0200 Subject: [PATCH] Fix indentation of scheduler_job_runner for standalone dag processor The indentation in #40802 has changed heartbeating to not work in case of standalone date processing. This PR fixes it back. --- airflow/jobs/scheduler_job_runner.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) 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():