rclone/main.nf at main · nf-modules-hub/rclone · GitHub

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
#!/usr/bin/env nextflow

include { COPY } from "./modules/nf-modules-hub/copy"


/*
#==============================================
rclone
#==============================================
*/

workflow RCLONE {

    if( params.samplesheet ) {

        ch_in_copy = Channel.fromPath( params.samplesheet )
                    .splitCsv(header: false, skip: 1)
                    .map{ row ->
                            {
                                source          = row[0]
                                target          = row[1]

                                return tuple([id:'bulk-copy'], source, target)
                            }
                        }

    } else {

        ch_in_copy = Channel.of([[id:'single-copy'], params.source, params.target])
    }


    COPY ( ch_in_copy )
}


workflow {
    RCLONE ()
}