diff --git a/airflow/models/dag.py b/airflow/models/dag.py index 2a08d269b30d7..477e597b49129 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -1343,7 +1343,6 @@ def get_task_instances( as_pk_tuple=False, session=session, ) - .join(TaskInstance.dag_run) .order_by(DagRun.execution_date) .all() )