diff --git a/workflows/seqinspector.nf b/workflows/seqinspector.nf index a89bd5c..972b2f3 100644 --- a/workflows/seqinspector.nf +++ b/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)