diff --git a/airflow/www/views.py b/airflow/www/views.py index 90d98a424c4a8..cf7c5c193b226 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -3611,11 +3611,12 @@ def gantt(self, dag_id: str, session: Session = NEW_SESSION): TaskInstance.state.is_not(None), ) .order_by(TaskInstance.start_date) - ) + ).all() ti_fails = select(TaskFail).filter_by(run_id=dag_run_id, dag_id=dag_id) if dag.partial: ti_fails = ti_fails.where(TaskFail.task_id.in_([t.task_id for t in dag.tasks])) + ti_fails = session.scalars(ti_fails) tasks = [] for ti in tis: