-
Notifications
You must be signed in to change notification settings - Fork 2
/
main.nf
155 lines (118 loc) · 6.17 KB
/
main.nf
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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
#!/usr/bin/env nextflow
/*
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
mikrokondo
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Github : https://github.com/mk-kondo/mikrokondo
----------------------------------------------------------------------------------------
*/
nextflow.enable.dsl = 2
// Enable for testing purposes only
// nextflow.enable.strict = true
/*
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
VALIDATE & PRINT PARAMETER SUMMARY
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
println '\033[0;32m ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\033[0m'
println '\033[0;32m 888b d888 d8b 888 888 d8P 888\033[0m'
println '\033[0;32m 8888b d8888 Y8P 888 888 d8P 888\033[0m'
println '\033[0;32m 88888b.d88888 888 888 d8P 888\033[0m'
println '\033[0;32m 888Y88888P888 888 888 888 888d888 .d88b. 888d88K .d88b. 88888b. .d88888 .d88b.\033[0m'
println '\033[0;32m 888 Y888P 888 888 888 .88P 888P" d88""88b 8888888b d88""88b 888 "88b d88" 888 d88""88b\033[0m'
println '\033[0;32m 888 Y8P 888 888 888888K 888 888 888 888 Y88b 888 888 888 888 888 888 888 888\033[0m'
println '\033[0;32m 888 " 888 888 888 "88b 888 Y88..88P 888 Y88b Y88..88P 888 888 Y88b 888 Y88..88P\033[0m'
println '\033[0;32m 888 888 888 888 888 888 "Y88P" 888 Y88b "Y88P" 888 888 "Y88888 "Y88P"\033[0m'
println '\033[0;32m ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\033[0m'
include { validateParameters; paramsHelp; paramsSummaryLog; paramsSummaryMap } from 'plugin/nf-validation'
if (params.help) {
log.info paramsHelp ("nextflow run main.nf --input input_file.csv --outdir ./output_place --platform {platform}")
exit 1
}
// Check mandatory parameters
if (params.input) { ch_input = file(params.input) } else { exit 1, 'Input samplesheet not specified!' }
/*
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
NAMED WORKFLOW FOR PIPELINE
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
include { CLEAN_ASSEMBLE_READS } from './workflows/CleanAssemble.nf'
include { POST_ASSEMBLY } from './workflows/PostAssembly.nf'
include { INPUT_CHECK } from './subworkflows/local/input_check.nf'
include { REPORT } from './modules/local/report.nf'
include { REPORT_AGGREGATE } from './modules/local/report_aggregate.nf'
include { GZIP_FILES } from './modules/local/gzip_files.nf'
include { CUSTOM_DUMPSOFTWAREVERSIONS } from './modules/nf-core/custom/dumpsoftwareversions/main'
import org.slf4j.LoggerFactory;
//
// WORKFLOW: Run main mk-kondo/mikrokondo analysis pipeline
//
workflow MIKROKONDO {
if(params.validate_params){
//====Temporarily turn of logging for ScriptBinding process that throws warns
// Probably better to disable the console appender briefly https://github.com/nextflow-io/nextflow/blob/6a0626f72455dfdef4135a119f48c3950bc6d9c6/modules/nextflow/src/main/groovy/nextflow/util/LoggerHelper.groovy#L110
def logger2 = LoggerFactory.getLogger(nextflow.script.ScriptBinding)
// This is working but if things get messy a better solution would be to look for a way to detach the console appender
logger2.setLevel(ch.qos.logback.classic.Level.ERROR)
validateParameters(monochrome_logs: params.monochrome_logs, monochromeLogs: params.monochrome_logs)
logger2.setLevel(ch.qos.logback.classic.Level.DEBUG)
}
log.info paramsSummaryLog(workflow)
ch_reports = Channel.empty()
prepped_data = INPUT_CHECK()
split_data = prepped_data.reads.branch{
post_assembly: it[0].assembly // [0] dentoes the meta tag
read_data: true
}
mk_out = CLEAN_ASSEMBLE_READS(split_data.read_data)
assembly_data = mk_out.final_assembly.mix(split_data.post_assembly.map{
meta, contigs -> tuple(meta, contigs, []) // appending empty brackets to match cardinality of the first processes output
})
ps_out = POST_ASSEMBLY(assembly_data, mk_out.cleaned_reads, mk_out.versions)
// Assemblies will be discared
base_count_data = ps_out.quast_table.map{
meta, reports, contigs -> tuple(meta, reports)
}.join(mk_out.base_counts)
ch_versions = ps_out.versions
ch_reports = ch_reports.mix(mk_out.reports)
ch_reports = ch_reports.mix(ps_out.reports)
ch_reports_all = ch_reports.collect()
if(!params.skip_report){
REPORT(ch_reports_all)
REPORT_AGGREGATE(REPORT.out.final_report)
ch_versions = ch_versions.mix(REPORT_AGGREGATE.out.versions)
updated_samples = REPORT_AGGREGATE.out.flat_samples.flatten().map{
sample ->
def name_trim = sample.getName()
def trimmed_name = name_trim.substring(0, name_trim.length() - params.report_aggregate.sample_flat_suffix.length())
tuple([
"id": trimmed_name,
"sample": trimmed_name],
sample)
}
GZIP_FILES(updated_samples)
ch_versions = ch_versions.mix(GZIP_FILES.out.versions)
}
if(!params.skip_version_gathering){
CUSTOM_DUMPSOFTWAREVERSIONS (
ch_versions.unique().collectFile(name: 'collated_versions.yml')
)
}
}
/*
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
RUN ALL WORKFLOWS
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
//
// WORKFLOW: Execute a single named workflow for the pipeline
// See: https://github.com/nf-core/rnaseq/issues/619
//
workflow {
MIKROKONDO ()
}
/*
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
THE END
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/