From d694911a7abf6ac45b001ffb65dc1dd7a7ba4dbf Mon Sep 17 00:00:00 2001 From: Ryan Hatter <25823361+RNHTTR@users.noreply.github.com> Date: Tue, 19 Apr 2022 14:20:31 -0400 Subject: [PATCH] Fix typo in scheduler_job.py Alternatively, we could say... "The reason we don't select all dagruns at once *is* because..." --- airflow/jobs/scheduler_job.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py index f3872c63a89d1..e0b8c437ac37a 100644 --- a/airflow/jobs/scheduler_job.py +++ b/airflow/jobs/scheduler_job.py @@ -881,7 +881,7 @@ def _do_scheduling(self, session) -> int: By "next oldest", we mean hasn't been examined/scheduled in the most time. - The reason we don't select all dagruns at once because the rows are selected with row locks, meaning + We don't select all dagruns at once, because the rows are selected with row locks, meaning that only one scheduler can "process them", even it is waiting behind other dags. Increasing this limit will allow more throughput for smaller DAGs but will likely slow down throughput for larger (>500 tasks.) DAGs