This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch new-tree-view
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/new-tree-view by this push:
new 23af0d0 apply reviews from code review
23af0d0 is described below
commit 23af0d0d956bcdf6bf212b0ecdcfe9910f2ec912
Author: Ephraim Anierobi <[email protected]>
AuthorDate: Sun Oct 10 16:13:55 2021 +0100
apply reviews from code review
---
airflow/www/views.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/airflow/www/views.py b/airflow/www/views.py
index bf075c7..2d5db14 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -229,9 +229,11 @@ def task_group_to_tree(task_group, dag, dag_runs, tis):
'id': task_group.task_id,
'instances': [wwwutils.encode_ti(ti) for ti in tis if ti.task_id
== task_group.task_id],
'label': task_group.label,
- 'extra_links': dag.get_task(task_group.task_id).extra_links,
+ 'extra_links': task_group.extra_links,
}
+ # Task Group
+
children = [task_group_to_tree(child, dag, dag_runs, tis) for child in
task_group.children.values()]
def get_summary(dag_run, children):
@@ -253,7 +255,7 @@ def task_group_to_tree(task_group, dag, dag_runs, tis):
'skipped',
]
- child_instances = [child['instances'] for child in children if
child.get('instances')]
+ child_instances = [child['instances'] for child in children if
'instances' in child]
child_instances = [item for sublist in child_instances for item in
sublist]
children_start_dates = [
