forked from mahsa-mousavi/eDNAFlow
-
Notifications
You must be signed in to change notification settings - Fork 0
/
nextflow.config
executable file
·114 lines (95 loc) · 2.61 KB
/
nextflow.config
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
manifest {
author = 'Mahsa Mousavi-Derazmahalleh'
name = 'eDNAFlow'
homePage = 'http://github.com/mahsa-mousavi/eDNAFlow'
description = 'Pipeline identifies Zotus using USEARCH unoise3'
mainScript = 'eDNAFlow.nf'
version = '1.0.0'
}
resume = true
trace {
fields = 'name,hash,status,exit,realtime,submit,%cpu,%mem'
}
/*
* Define the pipeline parameters
* Each of these parameters can be specified at command line (e.g. --barcode 'x.txt'); if none specified the below will be set as default
*/
params {
reads = "*_{R1,R2}.fastq"
barcode = "*_bc.txt"
minQuality = "20"
minAlignLeng = "12"
minLen = "50"
primer_mismatch = "2"
minsize = "8"
maxTarSeq = "10"
perc_identity = "95"
evalue = "1e-3"
qcov = "100"
lulu = "lulu.R"
mode = "usearch32"
usearch64 = ""
blast_db = ""
custom_db = ""
blast_task = "blastn"
publish_dir_mode = "symlink"
bindDir = ""
singularityDir = ""
lca_script = "LCA_taxonomyAssignment_scripts/runAssign_collapsedTaxonomy.py"
zotuTable = ""
blastFile = ""
lca_qcov = "100"
lca_pid = "97"
lca_diff = "1"
lca_output = "lca_taxAssigned_results"
minMatch_lulu="84"
test = false
help = false
// Defaults only, expecting to be overwritten
max_memory = 128.GB
max_cpus = 16
max_time = 240.h
}
// Load base.config by default for all pipelines
// move default values for singularity and process there and then enable
includeConfig 'conf/base.config'
// Load test parameters if required
if (params.test) {
includeConfig 'conf/initialTest.config'
}
// Load profiles from conf/profiles.config
profiles {
includeConfig 'conf/profiles.config'
}
// Function to ensure that resource requirements don't go beyond
// a maximum limit
def check_max(obj, type) {
if (type == 'memory') {
try {
if (obj.compareTo(params.max_memory as nextflow.util.MemoryUnit) == 1)
return params.max_memory as nextflow.util.MemoryUnit
else
return obj
} catch (all) {
println " ### ERROR ### Max memory '${params.max_memory}' is not valid! Using default value: $obj"
return obj
}
} else if (type == 'time') {
try {
if (obj.compareTo(params.max_time as nextflow.util.Duration) == 1)
return params.max_time as nextflow.util.Duration
else
return obj
} catch (all) {
println " ### ERROR ### Max time '${params.max_time}' is not valid! Using default value: $obj"
return obj
}
} else if (type == 'cpus') {
try {
return Math.min( obj, params.max_cpus as int )
} catch (all) {
println " ### ERROR ### Max cpus '${params.max_cpus}' is not valid! Using default value: $obj"
return obj
}
}
}