Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion modules/add_alt_allele_ratio_vcf.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process add_alt_allele_ratio_vcf {
label 'artic'
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy'
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy'
input:
tuple val(name), path(bam), path(bai), path(vcf), path(failed_vcf)
path(external_scheme) // primer scheme dir as input
Expand Down
2 changes: 1 addition & 1 deletion modules/filter_fastq_by_length.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process filter_fastq_by_length {
label 'ubuntu'
publishDir "${params.output}/${params.readsdir}/filtered_reads/", mode: 'copy', pattern: "${name}_filtered.fastq.gz"
publishDir "${params.output}/${params.readsdir}/filtered_reads/", mode: 'copy', pattern: { "${name}_filtered.fastq.gz" }
input:
tuple val(name), path(reads)
output:
Expand Down
3 changes: 2 additions & 1 deletion nextflow.config
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ params {
help = false
profile = false
trace_timestamp = new java.util.Date().format( 'yyyy-MM-dd_HH-mm-ss')
user = System.getenv('USER')

// inputs
fast5 = ''
Expand Down Expand Up @@ -116,7 +117,7 @@ profiles {


local {
workDir = "work/nextflow-poreCov-$USER"
workDir = "work/nextflow-poreCov-${params.user}"
includeConfig 'configs/local.config'
executor {
name = "local"
Expand Down
64 changes: 32 additions & 32 deletions workflows/process/artic.nf
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
process artic_medaka {
label 'artic'
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}_mapped_*.primertrimmed.sorted.bam*"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.trimmed.rg.sorted.bam"
publishDir "${params.output}/${params.genomedir}/all_consensus_sequences/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.primersitereport.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "SNP_${name}.pass.vcf"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.coverage_mask.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.fail.vcf"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}_mapped_*.primertrimmed.sorted.bam*" }
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.trimmed.rg.sorted.bam" }
publishDir { "${params.output}/${params.genomedir}/all_consensus_sequences/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.primersitereport.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "SNP_${name}.pass.vcf" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.coverage_mask.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.fail.vcf" }

input:
tuple val(name), path(reads), path(external_scheme)
Expand Down Expand Up @@ -68,14 +68,14 @@ process artic_medaka {

process artic_medaka_custom_bed {
label 'artic'
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}_mapped_*.primertrimmed.sorted.bam*"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.trimmed.rg.sorted.bam"
publishDir "${params.output}/${params.genomedir}/all_consensus_sequences/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.primersitereport.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "SNP_${name}.pass.vcf"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.coverage_mask.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.fail.vcf"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}_mapped_*.primertrimmed.sorted.bam*" }
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.trimmed.rg.sorted.bam" }
publishDir { "${params.output}/${params.genomedir}/all_consensus_sequences/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.primersitereport.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "SNP_${name}.pass.vcf" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.coverage_mask.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.fail.vcf" }

input:
tuple val(name), path(reads), path(external_scheme), path(primerBed)
Expand Down Expand Up @@ -148,14 +148,14 @@ process artic_medaka_custom_bed {

process artic_nanopolish {
label 'artic'
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}_mapped_*.primertrimmed.sorted.bam*"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.trimmed.rg.sorted.bam"
publishDir "${params.output}/${params.genomedir}/all_consensus_sequences/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.primersitereport.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "SNP_${name}.pass.vcf"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.coverage_mask.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.fail.vcf"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}_mapped_*.primertrimmed.sorted.bam*" }
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.trimmed.rg.sorted.bam" }
publishDir { "${params.output}/${params.genomedir}/all_consensus_sequences/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.primersitereport.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "SNP_${name}.pass.vcf" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.coverage_mask.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.fail.vcf" }

input:
tuple val(name), path(reads), path(external_scheme), path(fast5_dir), path(txt_files)
Expand Down Expand Up @@ -215,14 +215,14 @@ process artic_nanopolish {

process artic_nanopolish_custom_bed {
label 'artic'
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}_mapped_*.primertrimmed.sorted.bam*"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.trimmed.rg.sorted.bam"
publishDir "${params.output}/${params.genomedir}/all_consensus_sequences/", mode: 'copy', pattern: "*.consensus.fasta"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "${name}.primersitereport.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "SNP_${name}.pass.vcf"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.coverage_mask.txt"
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}.fail.vcf"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}_mapped_*.primertrimmed.sorted.bam*" }
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.trimmed.rg.sorted.bam" }
publishDir { "${params.output}/${params.genomedir}/all_consensus_sequences/" }, mode: 'copy', pattern: "*.consensus.fasta"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: { "${name}.primersitereport.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "SNP_${name}.pass.vcf" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.coverage_mask.txt" }
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}.fail.vcf" }

input:
tuple val(name), path(reads), path(external_scheme), path(fast5_dir), path(txt_files), path(primerBed)
Expand Down
4 changes: 2 additions & 2 deletions workflows/process/covarplot.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process covarplot {
label "covarplot"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy'
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy'
input:
tuple val(name), path(vcf), path(depth1), path(depth2), path(primerbed)
output:
Expand All @@ -20,7 +20,7 @@ process covarplot {

process covarplot_custom_bed {
label "covarplot"
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy'
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy'
input:
tuple val(name), path(vcf), path(depth1), path(depth2), path(primerbed)
output:
Expand Down
4 changes: 2 additions & 2 deletions workflows/process/freyja.nf
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ process freyja {
label 'freyja'
errorStrategy 'ignore'
maxRetries 1
publishDir "${params.output}/${params.lineagedir}/${name}/lineage-proportion-by-reads", mode: 'copy', pattern: "*"
publishDir { "${params.output}/${params.lineagedir}/${name}/lineage-proportion-by-reads" }, mode: 'copy', pattern: "*"

input:
tuple val(name), path(bam_file), path(reference)
Expand Down Expand Up @@ -69,7 +69,7 @@ process freyja {

process freyja_plot {
label 'freyja'
publishDir "${params.output}/${params.lineagedir}/", mode: 'copy', pattern: "*"
publishDir { "${params.output}/${params.lineagedir}/" }, mode: 'copy', pattern: "*"

input:
path(aggregate_file)
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/kraken2.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process kraken2 {
label 'kraken2'
publishDir "${params.output}/${params.readqcdir}/${name}/tax_read_classification", mode: 'copy'
publishDir { "${params.output}/${params.readqcdir}/${name}/tax_read_classification" }, mode: 'copy'
input:
tuple val(name), path(reads)
path(database)
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/krona.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process krona {
label 'krona'
publishDir "${params.output}/${params.readqcdir}/${name}/", mode: 'copy'
publishDir { "${params.output}/${params.readqcdir}/${name}/" }, mode: 'copy'
input:
tuple val(name), path(kraken2), path(kreport)
output:
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/lcs_sc2.nf
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ process lcs_ucsc_markers_table {

process lcs_sc2 {
label 'lcs_sc2'
publishDir "${params.output}/${params.lineagedir}/${name}/lineage-proportion-by-reads", mode: 'copy'
publishDir { "${params.output}/${params.lineagedir}/${name}/lineage-proportion-by-reads" }, mode: 'copy'
input:
tuple val(name), path(reads), path(ucsc_markers_table)
output:
Expand Down
8 changes: 4 additions & 4 deletions workflows/process/nanoplot.nf
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
process nanoplot {
label 'nanoplot'
publishDir "${params.output}/${params.readqcdir}/${name}/", mode: 'copy', pattern: "${name}_read_quality_report.html"
publishDir "${params.output}/${params.readqcdir}/${name}/", mode: 'copy', pattern: "${name}_read_quality.txt"
publishDir "${params.output}/${params.readqcdir}/${name}/figures", mode: 'copy', pattern: "*.png"
publishDir "${params.output}/${params.readqcdir}/${name}/vector_figures", mode: 'copy', pattern: "*.pdf"
publishDir { "${params.output}/${params.readqcdir}/${name}/" }, mode: 'copy', pattern: { "${name}_read_quality_report.html" }
publishDir { "${params.output}/${params.readqcdir}/${name}/" }, mode: 'copy', pattern: { "${name}_read_quality.txt" }
publishDir { "${params.output}/${params.readqcdir}/${name}/figures" }, mode: 'copy', pattern: "*.png"
publishDir { "${params.output}/${params.readqcdir}/${name}/vector_figures" }, mode: 'copy', pattern: "*.pdf"
input:
tuple val(name), path(reads)
output:
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/nextclade.nf
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
process nextclade {
label 'nextclade'
container { nextcladedocker }
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "${name}_clade.tsv"
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "${name}_clade.tsv" }
input:
tuple val(name), path(consensus)
val(nextcladedocker)
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/pangolin.nf
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
process pangolin {
label 'pangolin'
container { pangolindocker }
publishDir "${params.output}/${params.lineagedir}/${name}/", mode: 'copy', pattern: "lineage_report_${name}.csv"
publishDir { "${params.output}/${params.lineagedir}/${name}/" }, mode: 'copy', pattern: { "lineage_report_${name}.csv" }
input:
tuple val(name), path(fasta)
val(pangolindocker)
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/president.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process president {
label "president"
publishDir "${params.output}/${params.genomedir}/${name}", mode: 'copy',
publishDir { "${params.output}/${params.genomedir}/${name}" }, mode: 'copy',
saveAs: { filename -> if (filename.endsWith("${name}_report.tsv")) "${name}_seq_ident_check.tsv" }
input:
tuple val(name), path(fasta), path(reference_fasta)
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/pycoqc.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process pycoqc {
label 'pycoqc'
publishDir "${params.output}/${params.readqcdir}/", mode: 'copy', pattern: "${name}_sequencing_performance.html"
publishDir "${params.output}/${params.readqcdir}/", mode: 'copy', pattern: { "${name}_sequencing_performance.html" }
input:
tuple val(name), path(txt_files)
output:
Expand Down
2 changes: 1 addition & 1 deletion workflows/process/quality_genome_filter.nf
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
process quality_genome_filter {
label 'ubuntu'
publishDir "${params.output}/${params.genomedir}/${name}/", mode: 'copy', pattern: "error_report_*.txt"
publishDir { "${params.output}/${params.genomedir}/${name}/" }, mode: 'copy', pattern: "error_report_*.txt"
input:
tuple val(name), path(fasta)
output:
Expand Down
4 changes: 2 additions & 2 deletions workflows/process/rki_report.nf
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
process rki_report {
label "ubuntu"
publishDir "${params.output}/${params.rkidir}/valid", mode: 'copy', pattern: "rki_valid_report.csv"
publishDir "${params.output}/${params.rkidir}", mode: 'copy', pattern: "${readme}"
publishDir "${params.output}/${params.rkidir}", mode: 'copy', pattern: { "${readme}" }
input:
path(president_data)
path(readme)
Expand All @@ -27,7 +27,7 @@ process rki_report {
process rki_report_extended {
label "ubuntu"
publishDir "${params.output}/${params.rkidir}/valid", mode: 'copy', pattern: "rki_valid_report.csv"
publishDir "${params.output}/${params.rkidir}", mode: 'copy', pattern: "${readme}"
publishDir "${params.output}/${params.rkidir}", mode: 'copy', pattern: { "${readme}" }
input:
path(president_data)
path(readme)
Expand Down