fix typo in scheduler_job_runner (apache#44165)

astronomer · Nov 19, 2024 · 1bcd7ec · 1bcd7ec
1 parent b968307
commit 1bcd7ec
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py
@@ -250,7 +250,7 @@ def _log_memory_usage(self, signum: int, frame: FrameType | None) -> None:
         top_stats = snapshot.statistics("lineno")
         n = 10
         self.log.error(
-            "scheduler memory usgae:\n Top %d\n %s",
+            "scheduler memory usage:\n Top %d\n %s",
             n,
             "\n\t".join(map(str, top_stats[:n])),
         )
@@ -704,7 +704,7 @@ def _critical_section_enqueue_task_instances(self, session: Session) -> int:
 
         queued_tis = self._executable_task_instances_to_queued(max_tis, session=session)
 
-        # Sort queued TIs to there respective executor
+        # Sort queued TIs to their respective executor
         executor_to_queued_tis = self._executor_to_tis(queued_tis)
         for executor, queued_tis_per_executor in executor_to_queued_tis.items():
             self.log.info(