back to the past

Author: nggvs

workflows/seqinspector.nf

@@ -36,18 +36,16 @@ workflow SEQINSPECTOR {
     // MODULE: Run Seqkit sample to perform subsampling
     //
     if (params.sample_size > 0 ) {
-        ch_sample_sized = ch_samplesheet.join(
-            SEQTK_SAMPLE(
-                ch_samplesheet.map {
-                    meta, reads -> [meta, reads, params.sample_size]
-                }
-            ).reads, by: [0]
-        )
+        ch_sample_sized = SEQTK_SAMPLE(
+            ch_samplesheet.map {
+                meta, reads -> [meta, reads, params.sample_size]
+            }
+        ).reads
         ch_versions = ch_versions.mix(SEQTK_SAMPLE.out.versions.first())
     } else {
         // No do subsample
         ch_sample_sized = ch_samplesheet.map {
-            meta, reads -> [meta, reads, []]
+            meta, reads -> [meta, reads]
         }
     }
 
@@ -56,7 +54,7 @@ workflow SEQINSPECTOR {
     //
     FASTQC (
         ch_sample_sized.map {
-            meta, reads, subsampled -> [meta, reads]
+            meta, subsampled -> [meta, subsampled]
         }
     )
     ch_multiqc_files = ch_multiqc_files.mix(FASTQC.out.zip)