(airflow) branch main updated: fix typo in scheduler_job_runner (#44165)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 1bcd7ec2a4f fix typo in scheduler_job_runner (#44165)
1bcd7ec2a4f is described below

commit 1bcd7ec2a4f3cb1e61343b1301c5c26d6101ecb4
Author: GPK <gopidesupa...@gmail.com>
AuthorDate: Tue Nov 19 04:10:20 2024 +0000

    fix typo in scheduler_job_runner (#44165)
---
 airflow/jobs/scheduler_job_runner.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/airflow/jobs/scheduler_job_runner.py 
b/airflow/jobs/scheduler_job_runner.py
index de42ee01afd..dda49e4f843 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -250,7 +250,7 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
         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 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
 
         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(