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