split COLLATEKMER in 2 steps

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

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 ?: ''