diff --git a/src/main.nf b/src/main.nf
index f8524d88429ce48dc0f15804c21b69497117c99f..251ad366074f3a97a1048b9a92c2889ad768e334 100644
--- a/src/main.nf
+++ b/src/main.nf
@@ -8,7 +8,8 @@ params.kmer_size = 31
 include { SPLIT } from "./modules/split"
 include { FASTKMERS } from "./modules/fastkmers"
 include { MERGEKMER } from "./modules/mergekmer"
-include { COLLATEKMER } from "./modules/mergekmer"
+include { COLLATEKMER as COLLATEKMER1 } from "./modules/mergekmer"
+include { COLLATEKMER as COLLATEKMER2} from "./modules/mergekmer"
 
 
 Channel.fromPath( file(params.csv) )
@@ -25,5 +26,6 @@ workflow {
   SPLIT(fastq.r1.mix(fastq.r2))
   FASTKMERS(SPLIT.out.fastq.transpose())
   MERGEKMER(FASTKMERS.out.csv.groupTuple())
-  COLLATEKMER(MERGEKMER.out.csv.map{it -> it[1]}.collect())
+  COLLATEKMER1(MERGEKMER.out.csv.map{it -> it[1]}.collate(5))
+  COLLATEKMER2(COLLATEKMER1.out.csv.map{it -> it[1]}.collect())
 }
diff --git a/src/modules/mergekmer.nf b/src/modules/mergekmer.nf
index cc5b7d4c6b71a538b1ff6c6ec8bb8ec5a259222f..35fd56dfebaf954b17e4dc8156fb2ca5cff23098 100644
--- a/src/modules/mergekmer.nf
+++ b/src/modules/mergekmer.nf
@@ -36,8 +36,8 @@ process COLLATEKMER {
     path(csv)
 
     output:
-    tuple val(meta), path("*.csv"), emit: csv
-    path "versions.yml"           , emit: versions
+    tuple path("*.csv"), emit: csv
+    path "versions.yml", emit: versions
 
     script:
     def args = task.ext.args ?: ''