From 92adccbb369da15ac140f6d836e153c9d315e8f3 Mon Sep 17 00:00:00 2001 From: eriny Date: Wed, 8 Jan 2025 17:11:19 -0700 Subject: [PATCH] fixed ch_reads_contigs --- workflows/grandeur.nf | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/workflows/grandeur.nf b/workflows/grandeur.nf index 39237f5..8b6e8c6 100755 --- a/workflows/grandeur.nf +++ b/workflows/grandeur.nf @@ -27,11 +27,11 @@ workflow GRANDEUR { version_script main: - ch_for_multiqc = Channel.empty() - ch_for_summary = ch_genome_sizes - ch_for_flag = Channel.empty() - ch_versions = Channel.empty() - + ch_for_multiqc = Channel.empty() + ch_for_summary = ch_genome_sizes + ch_for_flag = Channel.empty() + ch_versions = Channel.empty() + ch_reads_contigs = ch_fastas.map{it -> tuple(it[0], it[1], null)} if ( params.sample_sheet || params.reads || params.sra_accessions ) { @@ -39,14 +39,13 @@ workflow GRANDEUR { ch_assembled = DE_NOVO_ALIGNMENT.out.contigs ch_contigs = ch_fastas.mix(DE_NOVO_ALIGNMENT.out.contigs) - ch_reads_contigs = ch_fastas.map{it -> tuple{it[0], it[1], null}}.mix(DE_NOVO_ALIGNMENT.out.reads_contigs) + ch_reads_contigs = ch_reads_contigs.mix(DE_NOVO_ALIGNMENT.out.reads_contigs) ch_clean_reads = DE_NOVO_ALIGNMENT.out.clean_reads ch_for_multiqc = ch_for_multiqc.mix(DE_NOVO_ALIGNMENT.out.for_multiqc) ch_versions = ch_versions.mix(DE_NOVO_ALIGNMENT.out.versions) } else { ch_contigs = ch_fastas - ch_reads_contigs = Channel.empty() ch_clean_reads = Channel.empty() ch_assembled = Channel.empty() }