Skip to content
Snippets Groups Projects
Verified Commit ea629173 authored by Laurent Modolo's avatar Laurent Modolo
Browse files

danpos: fix file_id handling

parent fa6ec732
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
src/nf_modules/danpos/main.nf
+ 22
− 22
View file @ ea629173
...@@ -17,7 +17,7 @@ process dpos_bam { ...@@ -17,7 +17,7 @@ process dpos_bam {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(bam_ip), path(bam_wce) tuple val(file_id), path(bam_ip), path(bam_wce)
output: output:
...@@ -71,7 +71,7 @@ process dpos_wig { ...@@ -71,7 +71,7 @@ process dpos_wig {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(wig_ip), path(wig_wce) tuple val(file_id), path(wig_ip), path(wig_wce)
output: output:
...@@ -130,25 +130,25 @@ process dpos_wigvswig { ...@@ -130,25 +130,25 @@ process dpos_wigvswig {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(wig_ip_a), path(wig_wce_a) tuple val(file_id_a), path(wig_ip_a), path(wig_wce_a)
tuple val(file_id), path(wig_ip_b), path(wig_wce_b) tuple val(file_id_b), path(wig_ip_b), path(wig_wce_b)
output: output:
tuple file_id, "${file_prefix}/pooled/*.wig" into wig tuple file_id_a, "${file_prefix}/pooled/*.wig" into wig
tuple val(file_id), path("${file_prefix}"), emit: folder tuple val(file_id_a), path("${file_prefix}"), emit: folder
script: script:
switch(file_id) { switch(file_id_a) {
case {it instanceof List}: case {it instanceof List}:
file_prefix = file_id[0] file_prefix = file_id_a[0]
break break
case {it instanceof Map}: case {it instanceof Map}:
file_prefix = file_id.values()[0] file_prefix = file_id_a.values()[0]
break break
default: default:
file_prefix = file_id file_prefix = file_id_a
break break
} }
...@@ -177,7 +177,7 @@ process dpeak_bam { ...@@ -177,7 +177,7 @@ process dpeak_bam {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(bam_ip), path(bam_wce) tuple val(file_id), path(bam_ip), path(bam_wce)
output: output:
...@@ -232,7 +232,7 @@ process dpeak_wig { ...@@ -232,7 +232,7 @@ process dpeak_wig {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(wig_ip), path(wig_wce) tuple val(file_id), path(wig_ip), path(wig_wce)
output: output:
...@@ -292,25 +292,25 @@ process dpeak_wigvswig { ...@@ -292,25 +292,25 @@ process dpeak_wigvswig {
} }
input: input:
tuple val(file_id), path(fastq) tuple val(fastq_id), path(fastq)
tuple val(file_id), path(wig_ip_a), path(wig_wce_a) tuple val(file_id_a), path(wig_ip_a), path(wig_wce_a)
tuple val(file_id), path(wig_ip_b), path(wig_wce_b) tuple val(file_id_b), path(wig_ip_b), path(wig_wce_b)
output: output:
tuple file_id, "${file_prefix}/pooled/*.wig" into wig tuple file_id_a, "${file_prefix}/pooled/*.wig" into wig
tuple val(file_id), path("${file_prefix}"), emit: folder tuple val(file_id_a), path("${file_prefix}"), emit: folder
script: script:
switch(file_id) { switch(file_id_a) {
case {it instanceof List}: case {it instanceof List}:
file_prefix = file_id[0] file_prefix = file_id_a[0]
break break
case {it instanceof Map}: case {it instanceof Map}:
file_prefix = file_id.values()[0] file_prefix = file_id_a.values()[0]
break break
default: default:
file_prefix = file_id file_prefix = file_id_a
break break
} }
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment