@@ -22,7 +22,7 @@ vim: syntax=groovy
22
22
*/
23
23
24
24
// Pipeline version
25
- version = 1.0
25
+ version = ' 1.0.2 '
26
26
27
27
// Configurable variables
28
28
params. project = false
@@ -41,6 +41,8 @@ params.download_fasta = false
41
41
params. download_gtf = false
42
42
params. hisatBuildMemory = 200 // Required amount of memory in GB to build HISAT2 index with splice sites
43
43
params. saveReference = false
44
+ params. saveTrimmed = false
45
+ params. saveAlignedIntermediates = false
44
46
params. reads = " data/*{1,2}.fastq.gz"
45
47
params. outdir = ' ./results'
46
48
@@ -148,6 +150,9 @@ log.info "R libraries : ${params.rlocation}"
148
150
log. info " Script dir : $baseDir "
149
151
log. info " Working dir : $workDir "
150
152
log. info " Output dir : ${ params.outdir} "
153
+ log. info " Save Reference : ${ params.saveReference} "
154
+ log. info " Save Trimmed : ${ params.saveTrimmed} "
155
+ log. info " Save Intermeds : ${ params.saveAlignedIntermediates} "
151
156
if ( params. pico ) log. info " Trim Profile : SMARTer Stranded Total RNA-Seq Kit - Pico Input"
152
157
if ( params. clip_r1 > 0 ) log. info " Trim R1 : ${ params.clip_r1} "
153
158
if ( params. clip_r2 > 0 ) log. info " Trim R2 : ${ params.clip_r2} "
@@ -380,7 +385,7 @@ process trim_galore {
380
385
saveAs : {filename ->
381
386
if (filename. indexOf(" _fastqc" ) > 0 ) " FastQC/$filename "
382
387
else if (filename. indexOf(" trimming_report.txt" ) > 0 ) " logs/$filename "
383
- else " $ filename "
388
+ else params . saveTrimmed ? filename : null
384
389
}
385
390
386
391
input :
@@ -434,7 +439,10 @@ if(params.aligner == 'star'){
434
439
process star {
435
440
tag " $prefix "
436
441
publishDir " ${ params.outdir} /STAR" , mode : ' copy' ,
437
- saveAs : {filename -> filename. indexOf(" .out" ) > 0 ? " logs/$filename " : " $filename " }
442
+ saveAs : {filename ->
443
+ if (filename. indexOf(" .out" ) > 0 ) " logs/$filename "
444
+ else params. saveAlignedIntermediates ? filename : null
445
+ }
438
446
439
447
input :
440
448
file reads from trimmed_reads
@@ -476,7 +484,10 @@ if(params.aligner == 'hisat2'){
476
484
process hisat2Align {
477
485
tag " $prefix "
478
486
publishDir " ${ params.outdir} /HISAT2" , mode : ' copy' ,
479
- saveAs : {filename -> filename. indexOf(" _log.txt" ) > 0 ? " logs/$filename " : " aligned/$filename " }
487
+ saveAs : {filename ->
488
+ if (filename. indexOf(" _log.txt" ) > 0 ) " logs/$filename "
489
+ else params. saveAlignedIntermediates ? filename : null
490
+ }
480
491
481
492
input :
482
493
file reads from trimmed_reads
@@ -528,7 +539,8 @@ if(params.aligner == 'hisat2'){
528
539
529
540
process hisat2_sortOutput {
530
541
tag " ${ hisat2_bam.baseName} "
531
- publishDir " ${ params.outdir} /HISAT2/aligned_sorted" , mode : ' copy'
542
+ publishDir " ${ params.outdir} /HISAT2" , mode : ' copy' ,
543
+ saveAs : {filename -> params. saveAlignedIntermediates ? " aligned_sorted/$filename " : null }
532
544
533
545
input :
534
546
file hisat2_bam
@@ -748,7 +760,7 @@ process merge_featureCounts {
748
760
publishDir " ${ params.outdir} /featureCounts" , mode : ' copy'
749
761
750
762
input :
751
- file input_files from featureCounts_to_merge. toList ()
763
+ file input_files from featureCounts_to_merge. collect ()
752
764
753
765
output :
754
766
file ' merged_gene_counts.txt'
0 commit comments