diff --git a/src/main.nf b/src/main.nf
index ea10ec887d3fa8a4caf2daaff6019baa1fa9e659..f0214c9d25467239934dbf5d0697d46400b6b0a7 100644
--- a/src/main.nf
+++ b/src/main.nf
@@ -27,5 +27,5 @@ workflow {
   FASTKMERS(SPLIT.out.fastq.transpose())
   MERGEKMER(FASTKMERS.out.csv.groupTuple(size: 10))
   MERGEKMER2(MERGEKMER.out.csv.groupTuple())
-  COLLATEKMER(MERGEKMER2.out.csv)
+  COLLATEKMER(MERGEKMER2.out.csv.map{it -> it[1]}.collect())
 }
diff --git a/src/modules/mergekmer.nf b/src/modules/mergekmer.nf
index 83368cc3627c4af3fcf162eae795c5e6f2d2d43d..cc5b7d4c6b71a538b1ff6c6ec8bb8ec5a259222f 100644
--- a/src/modules/mergekmer.nf
+++ b/src/modules/mergekmer.nf
@@ -28,12 +28,12 @@ process MERGEKMER {
 process COLLATEKMER {
     tag "$meta.id"
     label 'big_mem_mono_cpus'
-    publishDir "results/${meta.specie}/${meta.sex}/${meta.read}/", mode: 'copy'
+    publishDir "results/", mode: 'copy'
 
     container "lbmc/mergekmer:0.1.1"
 
     input:
-    tuple val(meta), path(csv)
+    path(csv)
 
     output:
     tuple val(meta), path("*.csv"), emit: csv
@@ -42,7 +42,7 @@ process COLLATEKMER {
     script:
     def args = task.ext.args ?: ''
     """
-    mergekmer --csv ${csv} --output ${meta.id}.csv --collate
+    mergekmer --csv ${csv} --output final.csv --collate
 
 
     cat <<-END_VERSIONS > versions.yml