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())) {