diff --git a/subworkflows/local/bakta_dbdownload_run.nf b/subworkflows/local/bakta_dbdownload_run.nf index 675adcb..6822ba6 100644 --- a/subworkflows/local/bakta_dbdownload_run.nf +++ b/subworkflows/local/bakta_dbdownload_run.nf @@ -43,9 +43,14 @@ workflow BAKTA_DBDOWNLOAD_RUN { // // MODULE: BAKTA, gene annotation // + // Setup input channel for Bakta process + ch_fasta + .combine(ch_baktadb) + .set{ ch_to_bakta } + ch_to_bakta.view() BAKTA_BAKTA ( - ch_fasta, - ch_baktadb, + ch_to_bakta.map{ meta, fasta, bakta_db -> [meta, fasta] }, + ch_to_bakta.map{ meta, fasta, bakta_db -> bakta_db }, [], [] )