File tree Expand file tree Collapse file tree 1 file changed +16
-5
lines changed Expand file tree Collapse file tree 1 file changed +16
-5
lines changed Original file line number Diff line number Diff line change @@ -61,14 +61,18 @@ def add_tags(original_wf, tags_list):
61
61
62
62
# WF metadata
63
63
if "tags" in original_wf .metadata :
64
- original_wf .metadata ["tags" ].extend (tags_list )
64
+ for t in tags_list :
65
+ if t not in original_wf .metadata ["tags" ]:
66
+ original_wf .metadata ["tags" ].append (t )
65
67
else :
66
68
original_wf .metadata ["tags" ] = tags_list
67
69
68
70
# FW metadata
69
71
for idx_fw in range (len (original_wf .fws )):
70
72
if "tags" in original_wf .fws [idx_fw ].spec :
71
- original_wf .fws [idx_fw ].spec ["tags" ].extend (tags_list )
73
+ for t in tags_list :
74
+ if t not in original_wf .fws [idx_fw ].spec ["tags" ]:
75
+ original_wf .fws [idx_fw ].spec ["tags" ].append (t )
72
76
else :
73
77
original_wf .fws [idx_fw ].spec ["tags" ] = tags_list
74
78
@@ -77,9 +81,16 @@ def add_tags(original_wf, tags_list):
77
81
for idx_fw , idx_t in idxs :
78
82
if "additional_fields" in original_wf .fws [idx_fw ].tasks [idx_t ].optional_params :
79
83
if "tags" in original_wf .fws [idx_fw ].tasks [idx_t ]["additional_fields" ]:
80
- original_wf .fws [idx_fw ].tasks [idx_t ]["additional_fields" ][
81
- "tags"
82
- ].extend (tags_list )
84
+ for t in tags_list :
85
+ if (
86
+ t
87
+ not in original_wf .fws [idx_fw ].tasks [idx_t ][
88
+ "additional_fields"
89
+ ]["tags" ]
90
+ ):
91
+ original_wf .fws [idx_fw ].tasks [idx_t ]["additional_fields" ][
92
+ "tags"
93
+ ].append (t )
83
94
else :
84
95
original_wf .fws [idx_fw ].tasks [idx_t ]["additional_fields" ][
85
96
"tags"
You can’t perform that action at this time.
0 commit comments