From 80829728af9e890057a2aba78ddecbc59f102c2a Mon Sep 17 00:00:00 2001 From: Jim Downie <19718667+prototaxites@users.noreply.github.com> Date: Thu, 1 Aug 2024 17:05:19 +0100 Subject: [PATCH 1/3] Update gtdbtk.nf --- subworkflows/local/gtdbtk.nf | 1 + 1 file changed, 1 insertion(+) diff --git a/subworkflows/local/gtdbtk.nf b/subworkflows/local/gtdbtk.nf index 95e343c8..aae4f9ae 100644 --- a/subworkflows/local/gtdbtk.nf +++ b/subworkflows/local/gtdbtk.nf @@ -76,6 +76,7 @@ workflow GTDBTK { .of(gtdb_dir) .map{['gtdb', it]} .groupTuple() + .first() } else { error("Unsupported object given to --gtdb, database must be supplied as either a directory or a .tar.gz file!") } From deab0076bf6c58272aafbcf9f0bae1b6473e41d5 Mon Sep 17 00:00:00 2001 From: Jim Downie <19718667+prototaxites@users.noreply.github.com> Date: Thu, 1 Aug 2024 17:33:49 +0100 Subject: [PATCH 2/3] Update gtdbtk.nf --- subworkflows/local/gtdbtk.nf | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/subworkflows/local/gtdbtk.nf b/subworkflows/local/gtdbtk.nf index aae4f9ae..21ef25b2 100644 --- a/subworkflows/local/gtdbtk.nf +++ b/subworkflows/local/gtdbtk.nf @@ -74,9 +74,8 @@ workflow GTDBTK { gtdb_dir = gtdb.listFiles() ch_db_for_gtdbtk = Channel .of(gtdb_dir) - .map{['gtdb', it]} - .groupTuple() - .first() + .collect() + .map { ["gtdb", it] } } else { error("Unsupported object given to --gtdb, database must be supplied as either a directory or a .tar.gz file!") } From 5b9c4f1386f800e9c0021eed7722522246bbbd65 Mon Sep 17 00:00:00 2001 From: Jim Downie <19718667+prototaxites@users.noreply.github.com> Date: Fri, 2 Aug 2024 09:23:23 +0100 Subject: [PATCH 3/3] Update CHANGELOG.md --- CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 93022c43..06bd879f 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -11,6 +11,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### `Fixed` +- [#646](https://github.com/nf-core/mag/pull/646) - GTDB-Tk directory input now creates a value channel so it runs for all entries to the process and not just the first (by @prototaxites). + ### `Dependencies` ### `Deprecated`