millironx/taxprofiler
1
0
Fork 0
mirror of https://github.com/MillironX/taxprofiler.git synced 2024-11-21 21:56:05 +00:00
Code Issues Releases Packages Activity

Logical ordering and improved commenting

Browse source
This commit is contained in:
James Fellows Yates 2023-03-17 22:38:05 +01:00
parent 68d131af34
commit 74bc6b7dd3
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
subworkflows/local/input_check.nf
View file

@ -23,16 +23,16 @@ workflow INPUT_CHECK {
.map { .map {
sample, rows -> sample, rows ->
def is_multirun = rows.size() > 1 def is_multirun = rows.size() > 1
[ is_multirun, rows ] [ rows, is_multirun ]
} }
.transpose(by: 1) .transpose(by: 0)
.map { .map {
is_multirun, row -> row, is_multirun ->
row['is_multirun'] = is_multirun row['is_multirun'] = is_multirun
return row return row
} }
// Split for context-dependent channel generation
ch_parsed_samplesheet = ch_split_samplesheet ch_parsed_samplesheet = ch_split_samplesheet
.branch { row -> .branch { row ->
fasta: row.fasta != '' fasta: row.fasta != ''
@ -40,8 +40,10 @@ workflow INPUT_CHECK {
fastq: true fastq: true
} }
// Channel generation
ch_fastq = ch_parsed_samplesheet.fastq ch_fastq = ch_parsed_samplesheet.fastq
.map { create_fastq_channel(it) } .map { create_fastq_channel(it) }
.dump(tag: "boop")
ch_nanopore = ch_parsed_samplesheet.nanopore ch_nanopore = ch_parsed_samplesheet.nanopore
.map { create_fastq_channel(it) } .map { create_fastq_channel(it) }