You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2023/03/07 16:16:22 UTC
[airflow] 15/23: Removed continue for not in (#29791)
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 <34...@users.noreply.github.com>
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,