From 9baafd09ad4f8ca36d3f2610280d30e4501be521 Mon Sep 17 00:00:00 2001 From: hubert-pietron Date: Thu, 30 Dec 2021 17:46:03 +0100 Subject: [PATCH] Removed duplicated TaskInstance.dag_run in Dag.get_task_instances() --- airflow/models/dag.py | 1 - 1 file changed, 1 deletion(-) diff --git a/airflow/models/dag.py b/airflow/models/dag.py index 89b79b98b5390..10a461640ebe7 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -1371,7 +1371,6 @@ def get_task_instances( session=session, ), ) - .join(TaskInstance.dag_run) .order_by(DagRun.execution_date) .all() )