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

Put map in the rigt place

Browse source
This commit is contained in:
James Fellows Yates 2022-04-12 10:51:27 +02:00
parent 8d68914192
commit a15c45b00c
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
subworkflows/local/profiling.nf
View file

@ -22,7 +22,6 @@ workflow PROFILING {
// e.g. output [DUMP: reads_plus_db] [['id':'2612', 'run_accession':'combined', 'instrument_platform':'ILLUMINA', 'single_end':1], <reads_path>/2612.merged.fastq.gz, ['tool':'malt', 'db_name':'mal95', 'db_params':'"-id 90"'], <db_path>/malt90] // e.g. output [DUMP: reads_plus_db] [['id':'2612', 'run_accession':'combined', 'instrument_platform':'ILLUMINA', 'single_end':1], <reads_path>/2612.merged.fastq.gz, ['tool':'malt', 'db_name':'mal95', 'db_params':'"-id 90"'], <db_path>/malt90]
ch_input_for_profiling = reads ch_input_for_profiling = reads
.combine(databases)
.map { .map {
meta, reads -> meta, reads ->
def meta_new = meta.clone() def meta_new = meta.clone()
@ -30,6 +29,7 @@ workflow PROFILING {
meta_new['id'] = meta_new['id'] + pairtype meta_new['id'] = meta_new['id'] + pairtype
[meta_new, reads] [meta_new, reads]
} }
.combine(databases)
.branch { .branch {
malt: it[2]['tool'] == 'malt' malt: it[2]['tool'] == 'malt'
kraken2: it[2]['tool'] == 'kraken2' kraken2: it[2]['tool'] == 'kraken2'