diff --git a/subworkflows/local/longread_preprocessing.nf b/subworkflows/local/longread_preprocessing.nf index 27e5e37..ccdbeb2 100644 --- a/subworkflows/local/longread_preprocessing.nf +++ b/subworkflows/local/longread_preprocessing.nf @@ -12,7 +12,7 @@ workflow LONGREAD_PREPROCESSING { main: ch_versions = Channel.empty() - ch_multiqc_files = Channel.empty() + = Channel.empty() if ( params.longread_qc_run_clip && !params.longread_qc_run_filter ) { PORECHOP ( reads ) @@ -30,6 +30,7 @@ workflow LONGREAD_PREPROCESSING { ch_processed_reads = FILTLONG ( reads.map{ meta, reads -> [meta, [], reads ]} ) ch_versions = ch_versions.mix(FILTLONG.out.versions.first()) + ch_multiqc_files = .mix( FILTLONG.out.log.collect{it[1]}.ifEmpty([])) } else { PORECHOP ( reads ) @@ -45,16 +46,16 @@ workflow LONGREAD_PREPROCESSING { ch_versions = ch_versions.mix(PORECHOP.out.versions.first()) ch_versions = ch_versions.mix(FILTLONG.out.versions.first()) + ch_multiqc_files = ch_multiqc_files.mix( FILTLONG.out.log.collect{it[1]}.ifEmpty([])) } FASTQC_PROCESSED ( ch_processed_reads ) - ch_multiqc_files = ch_multiqc_files.mix( FASTQC_PROCESSED.out.zip ) - ch_multiqc_files = ch_multiqc_files.mix( FILTLONG.out.log.collect{it[1]}.ifEmpty([])) + = .mix( FASTQC_PROCESSED.out.zip ) emit: reads = ch_processed_reads // channel: [ val(meta), [ reads ] ] versions = ch_versions // channel: [ versions.yml ] - mqc = ch_multiqc_files + mqc = }