diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index cd4a27d08977d..5a4df571b381d 100644 --- a/airflow/models/dagrun.py +++ b/airflow/models/dagrun.py @@ -292,6 +292,7 @@ def next_dagruns_to_examine( # TODO: Bake this query, it is run _A lot_ query = ( session.query(cls) + .with_hint(cls, "USE INDEX (idx_dag_run_running_dags)", dialect_name="mysql") .filter(cls.state == state, cls.run_type != DagRunType.BACKFILL_JOB) .join(DagModel, DagModel.dag_id == cls.dag_id) .filter(DagModel.is_paused == false(), DagModel.is_active == true())