separate databases from sanger infra; handle compression

sanger-tol · Nov 11, 2024 · 254fea1 · 254fea1
1 parent 17b38ee
commit 254fea1
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/subworkflows/local/busco_diamond_blastp.nf b/subworkflows/local/busco_diamond_blastp.nf
@@ -47,12 +47,11 @@ workflow BUSCO_DIAMOND {
         ch_fasta_with_lineage,
         "genome",
         ch_fasta_with_lineage.map { it[0].lineage_name },
-        busco_db,
+        busco_db.first(),
         [],
     )
     ch_versions = ch_versions.mix ( BUSCO.out.versions.first() )
 
-
     //
     // Tidy up the BUSCO output directories before publication
     //

diff --git a/subworkflows/local/input_check.nf b/subworkflows/local/input_check.nf
@@ -63,8 +63,6 @@ workflow INPUT_CHECK {
             taxdump: db_meta.type == "taxdump"
         }
 
-    ch_databases.blastp.view()
-
 
     //
     // SUBWORKFLOW: Process samplesheet

diff --git a/workflows/blobtoolkit.nf b/workflows/blobtoolkit.nf
@@ -35,7 +35,7 @@ if (params.lineage_tax_ids) { ch_lineage_tax_ids = Channel.fromPath(params.linea
 // Create channel for optional parameters
 if (params.busco_lineages) { ch_busco_lin = Channel.value(params.busco_lineages) } else { ch_busco_lin = Channel.value([]) }
 if (params.busco) {
-    ch_busco_db = Channel.fromPath(params.busco).map { tuple([ "type": "busco"], it ) }
+    ch_busco_db = Channel.fromPath(params.busco).first().map { tuple([ "type": "busco"], it ) }
 } else {
     ch_busco_db = Channel.value([])
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -63,8 +63,6 @@ workflow INPUT_CHECK { @@
                 taxdump: db_meta.type == "taxdump"
             }
-        ch_databases.blastp.view()
         //
         // SUBWORKFLOW: Process samplesheet
@@ Expand Down @@