Skip to content

Commit 1bcd7ec

Browse files
fix typo in scheduler_job_runner (#44165)
1 parent b968307 commit 1bcd7ec

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airflow/jobs/scheduler_job_runner.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ def _log_memory_usage(self, signum: int, frame: FrameType | None) -> None:
250250
top_stats = snapshot.statistics("lineno")
251251
n = 10
252252
self.log.error(
253-
"scheduler memory usgae:\n Top %d\n %s",
253+
"scheduler memory usage:\n Top %d\n %s",
254254
n,
255255
"\n\t".join(map(str, top_stats[:n])),
256256
)
@@ -704,7 +704,7 @@ def _critical_section_enqueue_task_instances(self, session: Session) -> int:
704704

705705
queued_tis = self._executable_task_instances_to_queued(max_tis, session=session)
706706

707-
# Sort queued TIs to there respective executor
707+
# Sort queued TIs to their respective executor
708708
executor_to_queued_tis = self._executor_to_tis(queued_tis)
709709
for executor, queued_tis_per_executor in executor_to_queued_tis.items():
710710
self.log.info(

0 commit comments

Comments
 (0)