-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmain.nf
32 lines (24 loc) · 1.23 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
println "*****************************************************"
println "* Nextflow <name> pipeline *"
println "* A Nextflow wrapper pipeline *"
println "* Written by <------------------------> *"
println "* <-------------Email----------> *"
println "* *"
println "*****************************************************"
println " Required Pipeline parameters "
println "-----------------------------------------------------"
println "Input Directory : $params.inputdir "
println "Output Directory : $params.outdir "
println "*****************************************************"
// Include modules
include { Test } from './modules/test.nf'
include { SplitSequences } from './modules/test.nf'
include { Reverse } from './modules/test.nf'
// Start main workflow
workflow {
Channel.fromPath(params.inputdir+"/*.fa",checkIfExists:true).set{input_ch}
split_ch = SplitSequences(input_ch)
Reverse(split_ch).view()
input_ch.map{ file -> tuple( file.baseName , file)}.set{mapped_input_ch}
Test(mapped_input_ch).view()
}