From bba68b501343b160f07eaec9fb969580c87ea9d8 Mon Sep 17 00:00:00 2001
From: Edmund Miller <git@edmundmiller.dev>
Date: Thu, 26 Sep 2024 14:33:42 -0500
Subject: [PATCH] refactor(grohmm): Use each input

Didn't know that was a thing!
---
 modules/local/grohmm/parametertuning/main.nf | 4 +++-
 subworkflows/local/grohmm/main.nf            | 8 +++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/modules/local/grohmm/parametertuning/main.nf b/modules/local/grohmm/parametertuning/main.nf
index d2c2ae77..c6b63eda 100644
--- a/modules/local/grohmm/parametertuning/main.nf
+++ b/modules/local/grohmm/parametertuning/main.nf
@@ -9,8 +9,10 @@ process GROHMM_PARAMETERTUNING {
         'community.wave.seqera.io/library/grohmm:833aa94cad4202ac' }"
 
     input:
-    tuple val(meta), path(bams), path(bais), val(UTS), val(LtProbB)
+    tuple val(meta), path(bams), path(bais)
     path gtf
+    each UTS
+    each LtProbB
 
     output:
     tuple val(meta), path("*.tuning.csv"), emit: tuning
diff --git a/subworkflows/local/grohmm/main.nf b/subworkflows/local/grohmm/main.nf
index bec93af9..260e737d 100644
--- a/subworkflows/local/grohmm/main.nf
+++ b/subworkflows/local/grohmm/main.nf
@@ -25,14 +25,12 @@ workflow GROHMM {
     ch_uts = channel.fromList((params.grohmm_min_uts..params.grohmm_max_uts).step(5))
     // -100..-400 by 50 for LtProbB
     ch_ltprobb = channel.fromList((params.grohmm_min_ltprobb..params.grohmm_max_ltprobb).step(50))
-    ch_bams_bais_uts_ltprobb =
-        bams_bais
-        .combine(ch_uts)
-        .combine(ch_ltprobb)
 
     GROHMM_PARAMETERTUNING (
-        ch_bams_bais_uts_ltprobb,
+        bams_bais,
         gtf,
+        ch_uts,
+        ch_ltprobb,
     )
         .tuning
         .collectFile(