This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-5-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit cc334d563bbbb99c288958618613c8d598d9e55b Author: Jose Sanchez <[email protected]> AuthorDate: Tue Feb 28 06:15:11 2023 +0100 Removed continue for not in (#29791) (cherry picked from commit 60d98a1bc2d54787fcaad5edac36ecfa484fb42b) --- 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 880d447699..7b535484de 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -2843,10 +2843,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,
