diff --git a/airflow/dag_processing/processor.py b/airflow/dag_processing/processor.py index d8a1f69850b81..6fd3d129ed960 100644 --- a/airflow/dag_processing/processor.py +++ b/airflow/dag_processing/processor.py @@ -377,7 +377,6 @@ def manage_slas(self, dag: DAG, session: Session = None) -> None: qry = ( session.query(TI.task_id, func.max(DR.execution_date).label('max_ti')) .join(TI.dag_run) - .with_hint(TI, 'USE INDEX (PRIMARY)', dialect_name='mysql') .filter(TI.dag_id == dag.dag_id) .filter(or_(TI.state == State.SUCCESS, TI.state == State.SKIPPED)) .filter(TI.task_id.in_(dag.task_ids))