@@ -16,7 +16,7 @@ workflow ASSEMBLE {
1616 ont_reads // meta, reads
1717 hifi_reads // meta, reads
1818 ch_input
19- genomescope_out
19+ genome_size
2020 meryl_kmers
2121
2222 main :
@@ -57,13 +57,14 @@ workflow ASSEMBLE {
5757 }
5858 if (params. ont) {
5959 ont_reads. set { flye_inputs }
60- if (params. genome_size == null && params. jellyfish) {
61- params. genome_size = genomescope_out
62- }
6360 }
6461 // Run flye
62+ flye_inputs
63+ .join(genome_size)
64+ .map { meta, reads, genomesize -> [meta + [ genome_size : genomesize ], reads] }
65+ .set { flye_inputs }
6566 FLYE (flye_inputs, params. flye_mode)
66- FLYE . out. fasta. set { ch_assembly }
67+ FLYE . out. fasta. map { meta, assembly -> [meta - meta . subMap( ' genome_size ' ), assembly] } . set { ch_assembly }
6768 ch_versions = ch_versions. mix(FLYE . out. versions)
6869 }
6970 if (params. assembler == " hifiasm" ) {
@@ -114,12 +115,14 @@ workflow ASSEMBLE {
114115 ch_versions = ch_versions. mix(HIFIASM . out. versions). mix(GFA_2_FA . out. versions)
115116
116117 // Run flye
117- ont_reads. set { flye_inputs }
118- if (params. genome_size == null && params. jellyfish) {
119- params. genome_size = genomescope_out
120- }
118+ ont_reads
119+ .join(genome_size)
120+ .map { meta, reads, genomesize -> [[id : meta. id, genome_size : genomesize], reads]}
121+ .set { flye_inputs }
122+
121123 FLYE (flye_inputs, params. flye_mode)
122124 FLYE . out. fasta
125+ .map { meta, assembly -> [[id : meta. id], assembly] }
123126 .join(
124127 GFA_2_FA . out. contigs_fasta
125128 )
@@ -148,7 +151,7 @@ workflow ASSEMBLE {
148151 Channel . empty(). set { ch_ref_bam }
149152 if (params. assembler == " flye" ) {
150153 flye_inputs
151- .map { it -> [it[ 0 ], it[ 1 ] ] }
154+ .map { meta, reads -> [[ id : meta . id ], reads ] }
152155 .set { longreads }
153156 }
154157 if (params. assembler == " hifiasm" || params. assembler == " flye_on_hifiasm" ) {
0 commit comments