From 270467ff0eb5154a88409fc258831c23c93f100c Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Wed, 5 Jul 2023 08:09:38 +0100 Subject: [PATCH] Fix mssql Connection is busy with results for another command --- airflow/www/views.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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: