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

Posted to commits@airflow.apache.org by je...@apache.org on 2022/01/28 21:25:28 UTC

[airflow] 15/17: Removed duplicated dag_run join in Dag.get_task_instances() (#20591)

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

jedcunningham pushed a commit to branch v2-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git

commit 762abfbc690d4cf9e15792b0d99fac16571b24a8
Author: hubert-pietron <94...@users.noreply.github.com>
AuthorDate: Thu Jan 27 06:20:17 2022 +0100

    Removed duplicated dag_run join in Dag.get_task_instances() (#20591)
    
    Co-authored-by: hubert-pietron <hu...@gmail.com>
    (cherry picked from commit 960f573615b5357677c10bd9f7ec11811a0355c6)
---
 airflow/models/dag.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/airflow/models/dag.py b/airflow/models/dag.py
index 2a08d26..477e597 100644
--- a/airflow/models/dag.py
+++ b/airflow/models/dag.py
@@ -1343,7 +1343,6 @@ class DAG(LoggingMixin):
                 as_pk_tuple=False,
                 session=session,
             )
-            .join(TaskInstance.dag_run)
             .order_by(DagRun.execution_date)
             .all()
         )