From 2da90f8420df66a84e4f7fae691b04b0968f4113 Mon Sep 17 00:00:00 2001 From: pfurio Date: Thu, 19 Sep 2024 15:06:41 +0200 Subject: [PATCH] analysis: avoid tag duplicates, #TASK-6445 --- .../opencb/opencga/analysis/workflow/NextFlowExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/opencga-analysis/src/main/java/org/opencb/opencga/analysis/workflow/NextFlowExecutor.java b/opencga-analysis/src/main/java/org/opencb/opencga/analysis/workflow/NextFlowExecutor.java index 0c0cde9a39..5189fcdec7 100644 --- a/opencga-analysis/src/main/java/org/opencb/opencga/analysis/workflow/NextFlowExecutor.java +++ b/opencga-analysis/src/main/java/org/opencb/opencga/analysis/workflow/NextFlowExecutor.java @@ -84,7 +84,7 @@ protected void check() throws Exception { ObjectMap attributes = new ObjectMap() .append("WORKFLOW_ID", workflow.getManager().getId()) .append("WORKFLOW_VERSION", workflow.getManager().getVersion()); - List tags = new LinkedList<>(); + Set tags = new HashSet<>(); tags.add(ID); tags.add(workflow.getManager().getId().name()); tags.add(workflow.getManager().getId() + ":" + workflow.getManager().getVersion()); @@ -92,7 +92,7 @@ protected void check() throws Exception { if (CollectionUtils.isNotEmpty(workflow.getTags())) { tags.addAll(workflow.getTags()); } - updateJobInformation(tags, attributes); + updateJobInformation(new ArrayList<>(tags), attributes); this.inputBindings = new LinkedList<>(); if (MapUtils.isNotEmpty(nextflowParams.getParams())) {