Skip to content

Commit 8e720b8

Browse files
committed
Fix indentation of scheduler_job_runner for standalone dag processor
The indentation in apache#40802 has changed heartbeating to not work in case of standalone date processing. This PR fixes it back.
1 parent 12e17d1 commit 8e720b8

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

airflow/jobs/scheduler_job_runner.py

+7-7
Original file line numberDiff line numberDiff line change
@@ -1139,14 +1139,14 @@ def _run_scheduler_loop(self) -> None:
11391139
if self.processor_agent:
11401140
self.processor_agent.heartbeat()
11411141

1142-
# Heartbeat the scheduler periodically
1143-
perform_heartbeat(
1144-
job=self.job, heartbeat_callback=self.heartbeat_callback, only_if_necessary=True
1145-
)
1142+
# Heartbeat the scheduler periodically
1143+
perform_heartbeat(
1144+
job=self.job, heartbeat_callback=self.heartbeat_callback, only_if_necessary=True
1145+
)
11461146

1147-
# Run any pending timed events
1148-
next_event = timers.run(blocking=False)
1149-
self.log.debug("Next timed event is in %f", next_event)
1147+
# Run any pending timed events
1148+
next_event = timers.run(blocking=False)
1149+
self.log.debug("Next timed event is in %f", next_event)
11501150

11511151
self.log.debug("Ran scheduling loop in %.2f seconds", timer.duration)
11521152
if span.is_recording():

0 commit comments

Comments
 (0)