diff --git a/main.nf b/main.nf index ef103355badbe45ac707c83d7b4b12a08f3a3f87..5109b84e90a662b73f51581da9d0d4aa43e206e3 100644 --- a/main.nf +++ b/main.nf @@ -153,18 +153,11 @@ if (params.input_paths){ raw_reads = Channel.create() raw_reads_2 = Channel.create() - if ( params.split_fastq ){ - Channel - .from( params.input_paths ) - .map { row -> [ row[0], [file(row[1][0]), file(row[1][1])]] } - .splitFastq( by: params.fastq_chunks_size, pe:true, file: true, compress:true) - .separate( raw_reads, raw_reads_2 ) { a -> [tuple(a[0], a[1]), tuple(a[0], a[1])] } - }else{ - Channel - .from( params.input_paths ) - .map { row -> [ row[0], [file(row[1][0]), file(row[1][1])]] } - .separate( raw_reads, raw_reads_2 ) { a -> [tuple(a[0] + "_R1", a[1][0]), tuple(a[0] + "_R2", a[1][1])] } - } + Channel + .from( params.input_paths ) + .map { row -> [ row[0], [file(row[1][0]), file(row[1][1])]] } + .separate( raw_reads, raw_reads_2 ) { a -> [tuple(a[0] + "_R1", a[1][0]), tuple(a[0] + "_R2", a[1][1])] } + }else{ raw_reads = Channel.create() raw_reads_2 = Channel.create()