diff --git a/src/main.nf b/src/main.nf
index 9ebe5e70cf4cf49a9c0da79fa974db91dfd62d39..1e27cd67acc90e3c21832dda8a03f9886298d63c 100644
--- a/src/main.nf
+++ b/src/main.nf
@@ -9,15 +9,14 @@ include { FASTKMERS } from "./modules/fastkmers.nf"
 
 Channel.fromPath( file(params.csv) )
                     .splitCsv(header: true)
-                    .map{row ->
+                    .multiMap{row ->
                         fastq_r1 = file("${row.r1}")
                         fastq_r2 = file("${row.r2}")
-                        meta = ['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex]
-			println(row)
-                        [meta, [fastq_r1, fastq_r2]]
+                        r1: [['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex, 'read': 'r1'], fastq_r1]
+                        r2: [['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex, 'read': 'r2'], fastq_r2]
                     }
                     .set{ fastq }
 
 workflow {
-  FASTKMERS(fastq)
+  FASTKMERS(fastq.r1.mix(fastq.r2))
 }