This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-3-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit ef5b4c96233a2970fe0bd73de29cfca820ccf0e4 Author: Denis Boulas <[email protected]> AuthorDate: Tue Aug 2 14:14:31 2022 +0300 Removed interfering force of index. (#25404) (cherry picked from commit 6778503784de403a7e62b25d9fffd1d6715f2c88) --- 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 469b55cfeb..b04a0ef985 100644 --- a/airflow/dag_processing/processor.py +++ b/airflow/dag_processing/processor.py @@ -375,7 +375,6 @@ class DagFileProcessor(LoggingMixin): 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))
