From 6778503784de403a7e62b25d9fffd1d6715f2c88 Mon Sep 17 00:00:00 2001 From: Denis Boulas Date: Tue, 2 Aug 2022 14:14:31 +0300 Subject: [PATCH] Removed interfering force of index. (#25404) --- airflow/dag_processing/processor.py | 1 - 1 file changed, 1 deletion(-) 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))