adjust io of fq2bam to be consistent (#6906)

* adjust io to be consistent * adjust meta to be consistent * fix meta
nf-core · Oct 30, 2024 · adf071f · adf071f
1 parent 3abde3d
commit adf071f
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 13 deletions.
diff --git a/modules/nf-core/parabricks/fq2bam/main.nf b/modules/nf-core/parabricks/fq2bam/main.nf
@@ -8,15 +8,15 @@ process PARABRICKS_FQ2BAM {
     tuple val(meta), path(reads)
     tuple val(meta2), path(fasta)
     tuple val(meta3), path(index)
-    path(interval_file)
+    tuple val(meta4), path(interval_file)
     path(known_sites)
 
     output:
     tuple val(meta), path("*.bam")  , emit: bam
     tuple val(meta), path("*.bai")  , emit: bai
+    tuple val(meta), path("*.table"), emit: bqsr_table          , optional:true
     path "versions.yml"             , emit: versions
     path "qc_metrics"               , emit: qc_metrics          , optional:true
-    path("*.table")                 , emit: bqsr_table          , optional:true
     path("duplicate-metrics.txt")   , emit: duplicate_metrics   , optional:true
 
     when:

diff --git a/modules/nf-core/parabricks/fq2bam/meta.yml b/modules/nf-core/parabricks/fq2bam/meta.yml
@@ -40,7 +40,11 @@ input:
         type: file
         description: reference BWA index
         pattern: "*.{amb,ann,bwt,pac,sa}"
-  - - interval_file:
+  - - meta4:
+        type: map
+        description: |
+          Groovy Map containing index information
+    - interval_file:
         type: file
         description: (optional) file(s) containing genomic intervals for use in base
           quality score recalibration (BQSR)
@@ -71,6 +75,17 @@ output:
           type: file
           description: index corresponding to sorted BAM file
           pattern: "*.bai"
+  - bqsr_table:
+      - meta:
+          type: map
+          description: |
+            Groovy Map containing sample information
+            e.g. [ id:'test']
+      - "*.table":
+          type: file
+          description: (optional) table from base quality score recalibration calculation,
+            to be used with parabricks/applybqsr
+          pattern: "*.table"
   - versions:
       - versions.yml:
           type: file
@@ -81,12 +96,6 @@ output:
           type: directory
           description: (optional) optional directory of qc metrics
           pattern: "qc_metrics"
-  - bqsr_table:
-      - "*.table":
-          type: file
-          description: (optional) table from base quality score recalibration calculation,
-            to be used with parabricks/applybqsr
-          pattern: "*.table"
   - duplicate_metrics:
       - duplicate-metrics.txt:
           type: file

diff --git a/modules/nf-core/parabricks/fq2bam/tests/main.nf.test b/modules/nf-core/parabricks/fq2bam/tests/main.nf.test
@@ -53,7 +53,7 @@ nextflow_process {
                     file('https://github.com/nf-core/test-datasets/raw/methylseq/reference/genome.fa', checkIfExists: true)
                 ])
 				input[2] = BWA_INDEX.out.index
-                input[3] = []
+                input[3] = [ [], [] ]
                 input[4] = []
                 """
             }
@@ -88,7 +88,7 @@ nextflow_process {
                     file('https://github.com/nf-core/test-datasets/raw/methylseq/reference/genome.fa', checkIfExists: true)
                 ])
 				input[2] = BWA_INDEX.out.index
-                input[3] = []
+                input[3] = [ [], [] ]
                 input[4] = []
                 """
             }
@@ -119,7 +119,7 @@ nextflow_process {
                     file(params.modules_testdata_base_path + 'genomics/sarscov2/genome/genome.fasta', checkIfExists: true)
                 ])
                 input[2] = BWA_INDEX_PE.out.index
-                input[3] = []
+                input[3] = [ [], [] ]
                 input[4] = []
                 """
             }
@@ -156,7 +156,7 @@ nextflow_process {
                     file(params.modules_testdata_base_path + 'genomics/sarscov2/genome/genome.fasta', checkIfExists: true)
                 ])
                 input[2] = BWA_INDEX_PE.out.index
-                input[3] = []
+                input[3] = [ [], [] ]
                 input[4] = []
                 """
             }