You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by ep...@apache.org on 2022/08/15 18:45:13 UTC

[airflow] 37/45: Removed interfering force of index. (#25404)

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 <de...@gmail.com>
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))