Order TIs by map_index (#27904)

(cherry picked from commit 820c5bb)
apache · Jan 11, 2023 · 5302cc2 · 5302cc2
1 parent cc02bdc
commit 5302cc2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
@@ -318,7 +318,7 @@ def _executable_task_instances_to_queued(self, max_tis: int, session: Session) -
                 .filter(not_(DM.is_paused))
                 .filter(TI.state == TaskInstanceState.SCHEDULED)
                 .options(selectinload("dag_model"))
-                .order_by(-TI.priority_weight, DR.execution_date)
+                .order_by(-TI.priority_weight, DR.execution_date, TI.map_index)
             )
 
             if starved_pools: