mirror of
https://github.com/MillironX/nf-core_modules.git
synced 2024-11-14 05:43:08 +00:00
Remove def software lines and emit versions channel as plural (#780)
* Remove def software line * Replace version with versions in emit statement * Fix default software names
This commit is contained in:
parent
de14533964
commit
7b3315591a
257 changed files with 271 additions and 524 deletions
|
@ -24,10 +24,9 @@ process ABACAS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.abacas*'), emit: results
|
tuple val(meta), path('*.abacas*'), emit: results
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
abacas.pl \\
|
abacas.pl \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process ADAPTERREMOVAL {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.fastq.gz'), emit: reads
|
tuple val(meta), path('*.fastq.gz'), emit: reads
|
||||||
tuple val(meta), path('*.log') , emit: log
|
tuple val(meta), path('*.log') , emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
if (meta.single_end) {
|
if (meta.single_end) {
|
||||||
|
|
|
@ -24,10 +24,9 @@ process AGRVATE {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("${fasta.baseName}-results/${fasta.baseName}-summary.tab"), emit: summary
|
tuple val(meta), path("${fasta.baseName}-results/${fasta.baseName}-summary.tab"), emit: summary
|
||||||
path "${fasta.baseName}-results" , emit: results_dir
|
path "${fasta.baseName}-results" , emit: results_dir
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
agrvate \\
|
agrvate \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process ALLELECOUNTER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.alleleCount"), emit: allelecount
|
tuple val(meta), path("*.alleleCount"), emit: allelecount
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
alleleCounter \\
|
alleleCounter \\
|
||||||
|
|
|
@ -27,7 +27,7 @@ process AMPS {
|
||||||
path "results/heatmap_overview_Wevid.pdf" , emit: summary_pdf
|
path "results/heatmap_overview_Wevid.pdf" , emit: summary_pdf
|
||||||
path "results/heatmap_overview_Wevid.tsv" , emit: tsv
|
path "results/heatmap_overview_Wevid.tsv" , emit: tsv
|
||||||
path "results/pdf_candidate_profiles/" , emit: candidate_pdfs
|
path "results/pdf_candidate_profiles/" , emit: candidate_pdfs
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
"""
|
"""
|
||||||
|
@ -41,7 +41,7 @@ process AMPS {
|
||||||
|
|
||||||
cat <<-END_VERSIONS > versions.yml
|
cat <<-END_VERSIONS > versions.yml
|
||||||
${getProcessName(task.process)}:
|
${getProcessName(task.process)}:
|
||||||
amps: \$(echo \$(hops --version 2>&1) | sed 's/HOPS version//')
|
${getSoftwareName(task.process)}: \$(echo \$(hops --version 2>&1) | sed 's/HOPS version//')
|
||||||
END_VERSIONS
|
END_VERSIONS
|
||||||
"""
|
"""
|
||||||
}
|
}
|
||||||
|
|
|
@ -26,10 +26,9 @@ process ARRIBA {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.fusions.tsv") , emit: fusions
|
tuple val(meta), path("*.fusions.tsv") , emit: fusions
|
||||||
tuple val(meta), path("*.fusions.discarded.tsv"), emit: fusions_fail
|
tuple val(meta), path("*.fusions.discarded.tsv"), emit: fusions_fail
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def blacklist = (options.args.contains('-b')) ? '' : '-f blacklist'
|
def blacklist = (options.args.contains('-b')) ? '' : '-f blacklist'
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process ARTIC_GUPPYPLEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.fastq.gz"), emit: fastq
|
tuple val(meta), path("*.fastq.gz"), emit: fastq
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
artic \\
|
artic \\
|
||||||
|
|
|
@ -40,10 +40,9 @@ process ARTIC_MINION {
|
||||||
tuple val(meta), path("${prefix}.pass.vcf.gz") , emit: vcf
|
tuple val(meta), path("${prefix}.pass.vcf.gz") , emit: vcf
|
||||||
tuple val(meta), path("${prefix}.pass.vcf.gz.tbi") , emit: tbi
|
tuple val(meta), path("${prefix}.pass.vcf.gz.tbi") , emit: tbi
|
||||||
tuple val(meta), path("*.json"), optional:true , emit: json
|
tuple val(meta), path("*.json"), optional:true , emit: json
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def version = scheme_version.toString().toLowerCase().replaceAll('v','')
|
def version = scheme_version.toString().toLowerCase().replaceAll('v','')
|
||||||
def fast5 = params.fast5_dir ? "--fast5-directory $fast5_dir" : ""
|
def fast5 = params.fast5_dir ? "--fast5-directory $fast5_dir" : ""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BAMALIGNCLEANER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BANDAGE_IMAGE {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.png'), emit: png
|
tuple val(meta), path('*.png'), emit: png
|
||||||
tuple val(meta), path('*.svg'), emit: svg
|
tuple val(meta), path('*.svg'), emit: svg
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
Bandage image $gfa ${prefix}.png $options.args
|
Bandage image $gfa ${prefix}.png $options.args
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BBMAP_ALIGN {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
input = meta.single_end ? "in=${fastq}" : "in=${fastq[0]} in2=${fastq[1]}"
|
input = meta.single_end ? "in=${fastq}" : "in=${fastq[0]} in2=${fastq[1]}"
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BBMAP_BBDUK {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.fastq.gz'), emit: reads
|
tuple val(meta), path('*.fastq.gz'), emit: reads
|
||||||
tuple val(meta), path('*.log') , emit: log
|
tuple val(meta), path('*.log') , emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def raw = meta.single_end ? "in=${reads[0]}" : "in1=${reads[0]} in2=${reads[1]}"
|
def raw = meta.single_end ? "in=${reads[0]}" : "in1=${reads[0]} in2=${reads[1]}"
|
||||||
def trimmed = meta.single_end ? "out=${prefix}.fastq.gz" : "out1=${prefix}_1.fastq.gz out2=${prefix}_2.fastq.gz"
|
def trimmed = meta.single_end ? "out=${prefix}.fastq.gz" : "out1=${prefix}_1.fastq.gz out2=${prefix}_2.fastq.gz"
|
||||||
|
|
|
@ -30,10 +30,9 @@ process BBMAP_BBSPLIT {
|
||||||
tuple val(meta), path('*primary*fastq.gz'), optional:true, emit: primary_fastq
|
tuple val(meta), path('*primary*fastq.gz'), optional:true, emit: primary_fastq
|
||||||
tuple val(meta), path('*fastq.gz') , optional:true, emit: all_fastq
|
tuple val(meta), path('*fastq.gz') , optional:true, emit: all_fastq
|
||||||
tuple val(meta), path('*txt') , optional:true, emit: stats
|
tuple val(meta), path('*txt') , optional:true, emit: stats
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
def avail_mem = 3
|
def avail_mem = 3
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BBMAP_INDEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path 'ref' , emit: index
|
path 'ref' , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bbmap.sh \\
|
bbmap.sh \\
|
||||||
ref=${fasta} \\
|
ref=${fasta} \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_CONCAT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz"), emit: vcf
|
tuple val(meta), path("*.gz"), emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools concat \\
|
bcftools concat \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_CONSENSUS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.fa'), emit: fasta
|
tuple val(meta), path('*.fa'), emit: fasta
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
cat $fasta | bcftools consensus $vcf $options.args > ${prefix}.fa
|
cat $fasta | bcftools consensus $vcf $options.args > ${prefix}.fa
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_FILTER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz"), emit: vcf
|
tuple val(meta), path("*.gz"), emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools filter \\
|
bcftools filter \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_ISEC {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("${prefix}"), emit: results
|
tuple val(meta), path("${prefix}"), emit: results
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools isec \\
|
bcftools isec \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_MERGE {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz"), emit: vcf
|
tuple val(meta), path("*.gz"), emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools merge -Oz \\
|
bcftools merge -Oz \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process BCFTOOLS_MPILEUP {
|
||||||
tuple val(meta), path("*.gz") , emit: vcf
|
tuple val(meta), path("*.gz") , emit: vcf
|
||||||
tuple val(meta), path("*.tbi") , emit: tbi
|
tuple val(meta), path("*.tbi") , emit: tbi
|
||||||
tuple val(meta), path("*stats.txt"), emit: stats
|
tuple val(meta), path("*stats.txt"), emit: stats
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
echo "${meta.id}" > sample_name.list
|
echo "${meta.id}" > sample_name.list
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BCFTOOLS_NORM {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz") , emit: vcf
|
tuple val(meta), path("*.gz") , emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools norm \\
|
bcftools norm \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process BCFTOOLS_QUERY {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz") , emit: vcf
|
tuple val(meta), path("*.gz") , emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def regions_file = regions ? "--regions-file ${regions}" : ""
|
def regions_file = regions ? "--regions-file ${regions}" : ""
|
||||||
def targets_file = targets ? "--targets-file ${targets}" : ""
|
def targets_file = targets ? "--targets-file ${targets}" : ""
|
||||||
|
|
|
@ -25,10 +25,9 @@ process BCFTOOLS_REHEADER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.vcf.gz"), emit: vcf
|
tuple val(meta), path("*.vcf.gz"), emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def update_sequences = fai ? "-f $fai" : ""
|
def update_sequences = fai ? "-f $fai" : ""
|
||||||
def new_header = header ? "-h $header" : ""
|
def new_header = header ? "-h $header" : ""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BCFTOOLS_STATS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*stats.txt"), emit: stats
|
tuple val(meta), path("*stats.txt"), emit: stats
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bcftools stats $options.args $vcf > ${prefix}.bcftools_stats.txt
|
bcftools stats $options.args $vcf > ${prefix}.bcftools_stats.txt
|
||||||
|
|
|
@ -26,10 +26,9 @@ process BCFTOOLS_VIEW {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gz") , emit: vcf
|
tuple val(meta), path("*.gz") , emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def regions_file = regions ? "--regions-file ${regions}" : ""
|
def regions_file = regions ? "--regions-file ${regions}" : ""
|
||||||
def targets_file = targets ? "--targets-file ${targets}" : ""
|
def targets_file = targets ? "--targets-file ${targets}" : ""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BEDTOOLS_BAMTOBED {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bed"), emit: bed
|
tuple val(meta), path("*.bed"), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_COMPLEMENT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bed'), emit: bed
|
tuple val(meta), path('*.bed'), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -25,10 +25,9 @@ process BEDTOOLS_GENOMECOV {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.${extension}"), emit: genomecov
|
tuple val(meta), path("*.${extension}"), emit: genomecov
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
if (intervals.name =~ /\.bam/) {
|
if (intervals.name =~ /\.bam/) {
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_GETFASTA {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*.fa" , emit: fasta
|
path "*.fa" , emit: fasta
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${bed.baseName}${options.suffix}" : "${bed.baseName}"
|
def prefix = options.suffix ? "${bed.baseName}${options.suffix}" : "${bed.baseName}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_INTERSECT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.${extension}"), emit: intersect
|
tuple val(meta), path("*.${extension}"), emit: intersect
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_MAKEWINDOWS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.tab"), emit: tab
|
tuple val(meta), path("*.tab"), emit: tab
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def arg_input = use_bed ? "-b $regions" : "-g $regions"
|
def arg_input = use_bed ? "-b $regions" : "-g $regions"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_MASKFASTA {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.fa"), emit: fasta
|
tuple val(meta), path("*.fa"), emit: fasta
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BEDTOOLS_MERGE {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bed'), emit: bed
|
tuple val(meta), path('*.bed'), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BEDTOOLS_SLOP {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bed"), emit: bed
|
tuple val(meta), path("*.bed"), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BEDTOOLS_SORT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bed'), emit: bed
|
tuple val(meta), path('*.bed'), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BEDTOOLS_SUBTRACT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bed"), emit: bed
|
tuple val(meta), path("*.bed"), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
bedtools \\
|
bedtools \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process BISMARK_ALIGN {
|
||||||
tuple val(meta), path("*bam") , emit: bam
|
tuple val(meta), path("*bam") , emit: bam
|
||||||
tuple val(meta), path("*report.txt"), emit: report
|
tuple val(meta), path("*report.txt"), emit: report
|
||||||
tuple val(meta), path("*fq.gz") , optional:true, emit: unmapped
|
tuple val(meta), path("*fq.gz") , optional:true, emit: unmapped
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def fastq = meta.single_end ? reads : "-1 ${reads[0]} -2 ${reads[1]}"
|
def fastq = meta.single_end ? reads : "-1 ${reads[0]} -2 ${reads[1]}"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BISMARK_DEDUPLICATE {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.deduplicated.bam") , emit: bam
|
tuple val(meta), path("*.deduplicated.bam") , emit: bam
|
||||||
tuple val(meta), path("*.deduplication_report.txt"), emit: report
|
tuple val(meta), path("*.deduplication_report.txt"), emit: report
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def seqtype = meta.single_end ? '-s' : '-p'
|
def seqtype = meta.single_end ? '-s' : '-p'
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BISMARK_GENOMEPREPARATION {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "BismarkIndex" , emit: index
|
path "BismarkIndex" , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bismark_genome_preparation \\
|
bismark_genome_preparation \\
|
||||||
$options.args \\
|
$options.args \\
|
||||||
|
|
|
@ -28,11 +28,10 @@ process BISMARK_METHYLATIONEXTRACTOR {
|
||||||
tuple val(meta), path("*.cov.gz") , emit: coverage
|
tuple val(meta), path("*.cov.gz") , emit: coverage
|
||||||
tuple val(meta), path("*_splitting_report.txt"), emit: report
|
tuple val(meta), path("*_splitting_report.txt"), emit: report
|
||||||
tuple val(meta), path("*.M-bias.txt") , emit: mbias
|
tuple val(meta), path("*.M-bias.txt") , emit: mbias
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def seqtype = meta.single_end ? '-s' : '-p'
|
def seqtype = meta.single_end ? '-s' : '-p'
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bismark_methylation_extractor \\
|
bismark_methylation_extractor \\
|
||||||
--bedGraph \\
|
--bedGraph \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BISMARK_REPORT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*report.{html,txt}"), emit: report
|
tuple val(meta), path("*report.{html,txt}"), emit: report
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bismark2report $options.args
|
bismark2report $options.args
|
||||||
|
|
||||||
|
|
|
@ -26,10 +26,9 @@ process BISMARK_SUMMARY {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*report.{html,txt}", emit: summary
|
path "*report.{html,txt}", emit: summary
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bismark2summary
|
bismark2summary
|
||||||
|
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BLAST_BLASTN {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.blastn.txt'), emit: txt
|
tuple val(meta), path('*.blastn.txt'), emit: txt
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
DB=`find -L ./ -name "*.ndb" | sed 's/.ndb//'`
|
DB=`find -L ./ -name "*.ndb" | sed 's/.ndb//'`
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BLAST_MAKEBLASTDB {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path 'blast_db' , emit: db
|
path 'blast_db' , emit: db
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
makeblastdb \\
|
makeblastdb \\
|
||||||
-in $fasta \\
|
-in $fasta \\
|
||||||
|
|
|
@ -25,11 +25,10 @@ process BOWTIE_ALIGN {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bam'), emit: bam
|
tuple val(meta), path('*.bam'), emit: bam
|
||||||
tuple val(meta), path('*.out'), emit: log
|
tuple val(meta), path('*.out'), emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
tuple val(meta), path('*fastq.gz'), optional:true, emit: fastq
|
tuple val(meta), path('*fastq.gz'), optional:true, emit: fastq
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def unaligned = params.save_unaligned ? "--un ${prefix}.unmapped.fastq" : ''
|
def unaligned = params.save_unaligned ? "--un ${prefix}.unmapped.fastq" : ''
|
||||||
def endedness = meta.single_end ? "$reads" : "-1 ${reads[0]} -2 ${reads[1]}"
|
def endedness = meta.single_end ? "$reads" : "-1 ${reads[0]} -2 ${reads[1]}"
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BOWTIE_BUILD {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path 'bowtie' , emit: index
|
path 'bowtie' , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
mkdir bowtie
|
mkdir bowtie
|
||||||
bowtie-build --threads $task.cpus $fasta bowtie/${fasta.baseName}
|
bowtie-build --threads $task.cpus $fasta bowtie/${fasta.baseName}
|
||||||
|
|
|
@ -25,11 +25,10 @@ process BOWTIE2_ALIGN {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bam'), emit: bam
|
tuple val(meta), path('*.bam'), emit: bam
|
||||||
tuple val(meta), path('*.log'), emit: log
|
tuple val(meta), path('*.log'), emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
tuple val(meta), path('*fastq.gz'), optional:true, emit: fastq
|
tuple val(meta), path('*fastq.gz'), optional:true, emit: fastq
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
if (meta.single_end) {
|
if (meta.single_end) {
|
||||||
def unaligned = params.save_unaligned ? "--un-gz ${prefix}.unmapped.fastq.gz" : ''
|
def unaligned = params.save_unaligned ? "--un-gz ${prefix}.unmapped.fastq.gz" : ''
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BOWTIE2_BUILD {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path 'bowtie2' , emit: index
|
path 'bowtie2' , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
mkdir bowtie2
|
mkdir bowtie2
|
||||||
bowtie2-build $options.args --threads $task.cpus $fasta bowtie2/${fasta.baseName}
|
bowtie2-build $options.args --threads $task.cpus $fasta bowtie2/${fasta.baseName}
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWA_ALN {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.sai"), emit: sai
|
tuple val(meta), path("*.sai"), emit: sai
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
if (meta.single_end) {
|
if (meta.single_end) {
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BWA_INDEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "bwa" , emit: index
|
path "bwa" , emit: index
|
||||||
path "versions.yml", emit: version
|
path "versions.yml", emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
mkdir bwa
|
mkdir bwa
|
||||||
bwa \\
|
bwa \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWA_MEM {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWA_SAMPE {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_group = meta.read_group ? "-r ${meta.read_group}" : ""
|
def read_group = meta.read_group ? "-r ${meta.read_group}" : ""
|
||||||
|
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWA_SAMSE {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_group = meta.read_group ? "-r ${meta.read_group}" : ""
|
def read_group = meta.read_group ? "-r ${meta.read_group}" : ""
|
||||||
|
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BWAMEM2_INDEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "bwamem2" , emit: index
|
path "bwamem2" , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
mkdir bwamem2
|
mkdir bwamem2
|
||||||
bwa-mem2 \\
|
bwa-mem2 \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWAMEM2_MEM {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process BWAMETH_ALIGN {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
def read_group = meta.read_group ? "-R ${meta.read_group}" : ""
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -23,10 +23,9 @@ process BWAMETH_INDEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "bwameth" , emit: index
|
path "bwameth" , emit: index
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
bwameth.py index $fasta
|
bwameth.py index $fasta
|
||||||
|
|
||||||
|
|
|
@ -23,7 +23,7 @@ process CAT_CAT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "${file_out}*" , emit: file_out
|
path "${file_out}*" , emit: file_out
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def file_list = files_in.collect { it.toString() }
|
def file_list = files_in.collect { it.toString() }
|
||||||
|
|
|
@ -23,7 +23,7 @@ process CAT_FASTQ {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.merged.fastq.gz"), emit: reads
|
tuple val(meta), path("*.merged.fastq.gz"), emit: reads
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
|
@ -34,10 +34,9 @@ process CHROMAP_CHROMAP {
|
||||||
tuple val(meta), path("*.bam") , optional:true, emit: bam
|
tuple val(meta), path("*.bam") , optional:true, emit: bam
|
||||||
tuple val(meta), path("*.tagAlign.gz"), optional:true, emit: tagAlign
|
tuple val(meta), path("*.tagAlign.gz"), optional:true, emit: tagAlign
|
||||||
tuple val(meta), path("*.pairs.gz") , optional:true, emit: pairs
|
tuple val(meta), path("*.pairs.gz") , optional:true, emit: pairs
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def args = options.args.tokenize()
|
def args = options.args.tokenize()
|
||||||
|
|
||||||
|
|
|
@ -25,10 +25,9 @@ process CHROMAP_INDEX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*.index" , emit: index
|
path "*.index" , emit: index
|
||||||
path "versions.yml", emit: version
|
path "versions.yml", emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = fasta.baseName
|
def prefix = fasta.baseName
|
||||||
"""
|
"""
|
||||||
chromap \\
|
chromap \\
|
||||||
|
|
|
@ -28,10 +28,9 @@ process CNVKIT {
|
||||||
tuple val(meta), path("*.cnn"), emit: cnn
|
tuple val(meta), path("*.cnn"), emit: cnn
|
||||||
tuple val(meta), path("*.cnr"), emit: cnr
|
tuple val(meta), path("*.cnr"), emit: cnr
|
||||||
tuple val(meta), path("*.cns"), emit: cns
|
tuple val(meta), path("*.cns"), emit: cns
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
cnvkit.py \\
|
cnvkit.py \\
|
||||||
batch \\
|
batch \\
|
||||||
|
|
|
@ -25,10 +25,9 @@ process COOLER_DIGEST {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*.bed" , emit: bed
|
path "*.bed" , emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
cooler digest \\
|
cooler digest \\
|
||||||
$options.args \\
|
$options.args \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process COOLER_DUMP {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bedpe"), emit: bedpe
|
tuple val(meta), path("*.bedpe"), emit: bedpe
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
cooler dump \\
|
cooler dump \\
|
||||||
|
|
|
@ -22,9 +22,9 @@ process CUSTOM_DUMPSOFTWAREVERSIONS {
|
||||||
path versions
|
path versions
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path 'software_versions.yml' , emit: yml
|
path "software_versions.yml" , emit: yml
|
||||||
path 'software_versions_mqc.yml', emit: mqc_yml
|
path "software_versions_mqc.yml", emit: mqc_yml
|
||||||
path 'versions.yml' , emit: versions
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process CUTADAPT {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.trim.fastq.gz'), emit: reads
|
tuple val(meta), path('*.trim.fastq.gz'), emit: reads
|
||||||
tuple val(meta), path('*.log') , emit: log
|
tuple val(meta), path('*.log') , emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def trimmed = meta.single_end ? "-o ${prefix}.trim.fastq.gz" : "-o ${prefix}_1.trim.fastq.gz -p ${prefix}_2.trim.fastq.gz"
|
def trimmed = meta.single_end ? "-o ${prefix}.trim.fastq.gz" : "-o ${prefix}_1.trim.fastq.gz -p ${prefix}_2.trim.fastq.gz"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -25,10 +25,9 @@ process DAMAGEPROFILER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("${prefix}"), emit: results
|
tuple val(meta), path("${prefix}"), emit: results
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -25,10 +25,9 @@ process DEEPTOOLS_COMPUTEMATRIX {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.mat.gz") , emit: matrix
|
tuple val(meta), path("*.mat.gz") , emit: matrix
|
||||||
tuple val(meta), path("*.mat.tab"), emit: table
|
tuple val(meta), path("*.mat.tab"), emit: table
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
computeMatrix \\
|
computeMatrix \\
|
||||||
|
|
|
@ -25,10 +25,9 @@ process DEEPTOOLS_PLOTFINGERPRINT {
|
||||||
tuple val(meta), path("*.pdf") , emit: pdf
|
tuple val(meta), path("*.pdf") , emit: pdf
|
||||||
tuple val(meta), path("*.raw.txt") , emit: matrix
|
tuple val(meta), path("*.raw.txt") , emit: matrix
|
||||||
tuple val(meta), path("*.qcmetrics.txt"), emit: metrics
|
tuple val(meta), path("*.qcmetrics.txt"), emit: metrics
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def extend = (meta.single_end && params.fragment_size > 0) ? "--extendReads ${params.fragment_size}" : ''
|
def extend = (meta.single_end && params.fragment_size > 0) ? "--extendReads ${params.fragment_size}" : ''
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process DEEPTOOLS_PLOTHEATMAP {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.pdf"), emit: pdf
|
tuple val(meta), path("*.pdf"), emit: pdf
|
||||||
tuple val(meta), path("*.tab"), emit: table
|
tuple val(meta), path("*.tab"), emit: table
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
plotHeatmap \\
|
plotHeatmap \\
|
||||||
|
|
|
@ -24,10 +24,9 @@ process DEEPTOOLS_PLOTPROFILE {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.pdf"), emit: pdf
|
tuple val(meta), path("*.pdf"), emit: pdf
|
||||||
tuple val(meta), path("*.tab"), emit: table
|
tuple val(meta), path("*.tab"), emit: table
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
plotProfile \\
|
plotProfile \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process DELLY_CALL {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bcf"), emit: bcf
|
tuple val(meta), path("*.bcf"), emit: bcf
|
||||||
tuple val(meta), path("*.csi"), emit: csi
|
tuple val(meta), path("*.csi"), emit: csi
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
delly \\
|
delly \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process DIAMOND_BLASTP {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.txt'), emit: txt
|
tuple val(meta), path('*.txt'), emit: txt
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
DB=`find -L ./ -name "*.dmnd" | sed 's/.dmnd//'`
|
DB=`find -L ./ -name "*.dmnd" | sed 's/.dmnd//'`
|
||||||
|
|
|
@ -26,10 +26,9 @@ process DIAMOND_BLASTX {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.txt'), emit: txt
|
tuple val(meta), path('*.txt'), emit: txt
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
DB=`find -L ./ -name "*.dmnd" | sed 's/.dmnd//'`
|
DB=`find -L ./ -name "*.dmnd" | sed 's/.dmnd//'`
|
||||||
|
|
|
@ -25,10 +25,9 @@ process DIAMOND_MAKEDB {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "${fasta}.dmnd", emit: db
|
path "${fasta}.dmnd", emit: db
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
diamond \\
|
diamond \\
|
||||||
makedb \\
|
makedb \\
|
||||||
|
|
|
@ -27,10 +27,9 @@ process DRAGONFLYE {
|
||||||
tuple val(meta), path("{flye,miniasm,raven}.fasta") , emit: raw_contigs
|
tuple val(meta), path("{flye,miniasm,raven}.fasta") , emit: raw_contigs
|
||||||
tuple val(meta), path("{miniasm,raven}-unpolished.gfa"), optional:true , emit: gfa
|
tuple val(meta), path("{miniasm,raven}-unpolished.gfa"), optional:true , emit: gfa
|
||||||
tuple val(meta), path("flye-info.txt"), optional:true , emit: txt
|
tuple val(meta), path("flye-info.txt"), optional:true , emit: txt
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def memory = task.memory.toGiga()
|
def memory = task.memory.toGiga()
|
||||||
"""
|
"""
|
||||||
dragonflye \\
|
dragonflye \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process DSHBIO_EXPORTSEGMENTS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.fa"), emit: fasta
|
tuple val(meta), path("*.fa"), emit: fasta
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
dsh-bio \\
|
dsh-bio \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process DSHBIO_FILTERBED {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bed.gz"), emit: bed
|
tuple val(meta), path("*.bed.gz"), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
dsh-bio \\
|
dsh-bio \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process DSHBIO_FILTERGFF3 {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gff3.gz"), emit: gff3
|
tuple val(meta), path("*.gff3.gz"), emit: gff3
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
dsh-bio \\
|
dsh-bio \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process DSHBIO_SPLITBED {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bed.gz"), emit: bed
|
tuple val(meta), path("*.bed.gz"), emit: bed
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
dsh-bio \\
|
dsh-bio \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process DSHBIO_SPLITGFF3 {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.gff3.gz"), emit: gff3
|
tuple val(meta), path("*.gff3.gz"), emit: gff3
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
dsh-bio \\
|
dsh-bio \\
|
||||||
|
|
|
@ -33,10 +33,9 @@ process ENSEMBLVEP {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.ann.vcf"), emit: vcf
|
tuple val(meta), path("*.ann.vcf"), emit: vcf
|
||||||
path "*.summary.html" , emit: report
|
path "*.summary.html" , emit: report
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
dir_cache = params.use_cache ? "\${PWD}/${cache}" : "/.vep"
|
dir_cache = params.use_cache ? "\${PWD}/${cache}" : "/.vep"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -25,10 +25,9 @@ process EXPANSIONHUNTER {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.vcf"), emit: vcf
|
tuple val(meta), path("*.vcf"), emit: vcf
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def gender = (meta.gender == 'male' || meta.gender == 1 || meta.gender == 'XY') ? "male" : "female"
|
def gender = (meta.gender == 'male' || meta.gender == 1 || meta.gender == 'XY') ? "male" : "female"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -24,10 +24,9 @@ process FASTANI {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.ani.txt"), emit: ani
|
tuple val(meta), path("*.ani.txt"), emit: ani
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
|
|
||||||
if (meta.batch_input) {
|
if (meta.batch_input) {
|
||||||
|
|
|
@ -28,13 +28,12 @@ process FASTP {
|
||||||
tuple val(meta), path('*.json') , emit: json
|
tuple val(meta), path('*.json') , emit: json
|
||||||
tuple val(meta), path('*.html') , emit: html
|
tuple val(meta), path('*.html') , emit: html
|
||||||
tuple val(meta), path('*.log') , emit: log
|
tuple val(meta), path('*.log') , emit: log
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
tuple val(meta), path('*.fail.fastq.gz') , optional:true, emit: reads_fail
|
tuple val(meta), path('*.fail.fastq.gz') , optional:true, emit: reads_fail
|
||||||
tuple val(meta), path('*.merged.fastq.gz'), optional:true, emit: reads_merged
|
tuple val(meta), path('*.merged.fastq.gz'), optional:true, emit: reads_merged
|
||||||
|
|
||||||
script:
|
script:
|
||||||
// Added soft-links to original fastqs for consistent naming in MultiQC
|
// Added soft-links to original fastqs for consistent naming in MultiQC
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
if (meta.single_end) {
|
if (meta.single_end) {
|
||||||
def fail_fastq = save_trimmed_fail ? "--failed_out ${prefix}.fail.fastq.gz" : ''
|
def fail_fastq = save_trimmed_fail ? "--failed_out ${prefix}.fail.fastq.gz" : ''
|
||||||
|
|
|
@ -24,7 +24,7 @@ process FASTQC {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.html"), emit: html
|
tuple val(meta), path("*.html"), emit: html
|
||||||
tuple val(meta), path("*.zip") , emit: zip
|
tuple val(meta), path("*.zip") , emit: zip
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
// Add soft-links to original FastQs for consistent naming in pipeline
|
// Add soft-links to original FastQs for consistent naming in pipeline
|
||||||
|
@ -36,7 +36,7 @@ process FASTQC {
|
||||||
|
|
||||||
cat <<-END_VERSIONS > versions.yml
|
cat <<-END_VERSIONS > versions.yml
|
||||||
${getProcessName(task.process)}:
|
${getProcessName(task.process)}:
|
||||||
fastqc: \$( fastqc --version | sed -e "s/FastQC v//g" )
|
${getSoftwareName(task.process)}: \$( fastqc --version | sed -e "s/FastQC v//g" )
|
||||||
END_VERSIONS
|
END_VERSIONS
|
||||||
"""
|
"""
|
||||||
} else {
|
} else {
|
||||||
|
@ -47,7 +47,7 @@ process FASTQC {
|
||||||
|
|
||||||
cat <<-END_VERSIONS > versions.yml
|
cat <<-END_VERSIONS > versions.yml
|
||||||
${getProcessName(task.process)}:
|
${getProcessName(task.process)}:
|
||||||
fastqc: \$( fastqc --version | sed -e "s/FastQC v//g" )
|
${getSoftwareName(task.process)}: \$( fastqc --version | sed -e "s/FastQC v//g" )
|
||||||
END_VERSIONS
|
END_VERSIONS
|
||||||
"""
|
"""
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,10 +22,9 @@ process FASTTREE {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*.tre", emit: phylogeny
|
path "*.tre", emit: phylogeny
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
"""
|
"""
|
||||||
fasttree \\
|
fasttree \\
|
||||||
$options.args \\
|
$options.args \\
|
||||||
|
|
|
@ -22,10 +22,9 @@ process FGBIO_CALLMOLECULARCONSENSUSREADS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
fgbio \\
|
fgbio \\
|
||||||
|
|
|
@ -22,10 +22,9 @@ process FGBIO_SORTBAM {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
fgbio \\
|
fgbio \\
|
||||||
|
|
|
@ -22,10 +22,9 @@ process FLASH {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.fastq.gz"), emit: reads
|
tuple val(meta), path("*.fastq.gz"), emit: reads
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
flash \\
|
flash \\
|
||||||
|
|
|
@ -27,10 +27,9 @@ process GATK4_APPLYBQSR {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def interval = intervals ? "-L ${intervals}" : ""
|
def interval = intervals ? "-L ${intervals}" : ""
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -29,10 +29,9 @@ process GATK4_BASERECALIBRATOR {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.table"), emit: table
|
tuple val(meta), path("*.table"), emit: table
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def intervalsCommand = intervalsBed ? "-L ${intervalsBed}" : ""
|
def intervalsCommand = intervalsBed ? "-L ${intervalsBed}" : ""
|
||||||
def sitesCommand = knownSites.collect{"--known-sites ${it}"}.join(' ')
|
def sitesCommand = knownSites.collect{"--known-sites ${it}"}.join(' ')
|
||||||
|
|
|
@ -24,10 +24,9 @@ process GATK4_BEDTOINTERVALLIST {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.interval_list'), emit: interval_list
|
tuple val(meta), path('*.interval_list'), emit: interval_list
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
gatk BedToIntervalList \\
|
gatk BedToIntervalList \\
|
||||||
|
|
|
@ -23,10 +23,9 @@ process GATK4_CREATESEQUENCEDICTIONARY {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
path "*.dict" , emit: dict
|
path "*.dict" , emit: dict
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def avail_mem = 6
|
def avail_mem = 6
|
||||||
if (!task.memory) {
|
if (!task.memory) {
|
||||||
log.info '[GATK] Available memory not known - defaulting to 6GB. Specify process memory requirements to change this.'
|
log.info '[GATK] Available memory not known - defaulting to 6GB. Specify process memory requirements to change this.'
|
||||||
|
|
|
@ -23,10 +23,9 @@ process GATK4_FASTQTOSAM {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam"), emit: bam
|
tuple val(meta), path("*.bam"), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def read_files = meta.single_end ? "-F1 $reads" : "-F1 ${reads[0]} -F2 ${reads[1]}"
|
def read_files = meta.single_end ? "-F1 $reads" : "-F1 ${reads[0]} -F2 ${reads[1]}"
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -26,10 +26,9 @@ process GATK4_GETPILEUPSUMMARIES {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.pileups.table'), emit: table
|
tuple val(meta), path('*.pileups.table'), emit: table
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def sitesCommand = ''
|
def sitesCommand = ''
|
||||||
|
|
||||||
|
|
|
@ -27,10 +27,9 @@ process GATK4_HAPLOTYPECALLER {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.vcf.gz"), emit: vcf
|
tuple val(meta), path("*.vcf.gz"), emit: vcf
|
||||||
tuple val(meta), path("*.tbi") , emit: tbi
|
tuple val(meta), path("*.tbi") , emit: tbi
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
def avail_mem = 3
|
def avail_mem = 3
|
||||||
if (!task.memory) {
|
if (!task.memory) {
|
||||||
|
|
|
@ -23,10 +23,9 @@ process GATK4_INTERVALLISTTOOLS {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*_split/*/*.interval_list"), emit: interval_list
|
tuple val(meta), path("*_split/*/*.interval_list"), emit: interval_list
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
|
|
@ -24,10 +24,9 @@ process GATK4_MARKDUPLICATES {
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path("*.bam") , emit: bam
|
tuple val(meta), path("*.bam") , emit: bam
|
||||||
tuple val(meta), path("*.metrics"), emit: metrics
|
tuple val(meta), path("*.metrics"), emit: metrics
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
gatk MarkDuplicates \\
|
gatk MarkDuplicates \\
|
||||||
|
|
|
@ -26,10 +26,9 @@ process GATK4_MERGEBAMALIGNMENT {
|
||||||
|
|
||||||
output:
|
output:
|
||||||
tuple val(meta), path('*.bam'), emit: bam
|
tuple val(meta), path('*.bam'), emit: bam
|
||||||
path "versions.yml" , emit: version
|
path "versions.yml" , emit: versions
|
||||||
|
|
||||||
script:
|
script:
|
||||||
def software = getSoftwareName(task.process)
|
|
||||||
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
def prefix = options.suffix ? "${meta.id}${options.suffix}" : "${meta.id}"
|
||||||
"""
|
"""
|
||||||
gatk MergeBamAlignment \\
|
gatk MergeBamAlignment \\
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show more
Loading…
Reference in a new issue