[airflow] branch main updated: Removed continue for not in (#29791)

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbovenzi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 60d98a1bc2 Removed continue for not in (#29791)
60d98a1bc2 is described below

commit 60d98a1bc2d54787fcaad5edac36ecfa484fb42b
Author: Jose Sanchez <34...@users.noreply.github.com>
AuthorDate: Tue Feb 28 06:15:11 2023 +0100

    Removed continue for not in (#29791)
---
 airflow/www/views.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/airflow/www/views.py b/airflow/www/views.py
index 6a6a9fb02b..8e6ad1981e 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -2919,10 +2919,10 @@ class Airflow(AirflowBaseView):
         form = GraphForm(data=dt_nr_dr_data)
         form.execution_date.choices = dt_nr_dr_data["dr_choices"]
 
-        task_instances = {
-            ti.task_id: wwwutils.get_instance_with_map(ti, session)
-            for ti in dag.get_task_instances(dttm, dttm)
-        }
+        task_instances = {}
+        for ti in dag.get_task_instances(dttm, dttm):
+            if ti.task_id not in task_instances:
+                task_instances[ti.task_id] = wwwutils.get_instance_with_map(ti, session)
         tasks = {
             t.task_id: {
                 "dag_id": t.dag_id,