You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/08/02 11:14:47 UTC

[airflow] branch main updated: Removed interfering force of index. (#25404)

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 6778503784 Removed interfering force of index. (#25404)
6778503784 is described below

commit 6778503784de403a7e62b25d9fffd1d6715f2c88
Author: Denis Boulas <de...@gmail.com>
AuthorDate: Tue Aug 2 14:14:31 2022 +0300

    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 d8a1f69850..6fd3d129ed 100644
--- a/airflow/dag_processing/processor.py
+++ b/airflow/dag_processing/processor.py
@@ -377,7 +377,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))