Fix mssql Connection is busy with results for another command

apache · Jul 5, 2023 · 270467f · 270467f
1 parent 70be0f4
commit 270467f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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: