@@ -10,7 +10,7 @@ nextflow.enable.dsl=2
1010 */
1111
1212// Pipeline version
13- version = ' 4.0 '
13+ version = ' 4.1 '
1414
1515params. help = false
1616params. resume = false
@@ -157,6 +157,9 @@ switch(params.demultiplexing) {
157157 case " seqtagger" :
158158 demux_models = " ${ projectDir} /seqtagger_models/"
159159 break ;
160+ case " seqtagger-trna" :
161+ demux_models = " ${ projectDir} /seqtagger_tRNA_models/"
162+ break ;
160163 case " dorado" :
161164 demux_models = " ${ projectDir} /seqtagger_models/"
162165 break ;
@@ -228,12 +231,16 @@ checkTools(tools, params.progPars)
228231progPars[" basecalling" ][" dorado-mod" ] = progPars[" basecalling" ][" dorado-mod" ] + " --emit-moves"
229232
230233def basecaller_pars = [" dorado" : progPars[" basecalling" ][" dorado" ], " dorado-duplex" : progPars[" basecalling" ][" dorado" ], " dorado-mod" : progPars[" basecalling" ][" dorado-mod" ] ]
231- def demux_pars = [ " dorado" : progPars[" basecalling" ][" dorado" ] + " " + progPars[" demultiplexing" ][" dorado" ], " seqtagger" : progPars[" demultiplexing" ][" seqtagger" ] ]
234+ def demux_pars = [ " dorado" : progPars[" basecalling" ][" dorado" ] + " " + progPars[" demultiplexing" ][" dorado" ], " seqtagger" : progPars[" demultiplexing" ][" seqtagger" ], " seqtagger-trna " : progPars[ " demultiplexing " ][ " seqtagger-trna " ] ]
232235def mapping_pars = [" bwa" : progPars[" mapping" ][" bwa" ], " winnowmap" : progPars[" mapping" ][" winnowmap" ] + " -y" ,
233236 " graphmap2" : progPars[" mapping" ][" graphmap2" ], " minimap2" : progPars[" mapping" ][" minimap2" ] + " -y --MD" ,
234237 " graphmap" : progPars[" mapping" ][" graphmap" ]
235238 ]
236239
240+ if (params. demultiplexing == " seqtagger-trna" ) {
241+ dem_cont = " lpryszcz/seqtagger:1.1a"
242+ }
243+
237244// INCLUDE WORKFLOWS
238245include { BASECALL } from " ${ workflowsDir} /basecaller" addParams(gpu : gpu_bc, output : output_bc, label : basecall_label, label2 :' big_cpus' , type :basecalling , extrapars : basecaller_pars[basecalling], models : dorado_models )
239246include { DEMULTIPLEX } from " ${ workflowsDir} /demultiplexer.nf" addParams(gpu : gpu, output : output_bc, label : basecall_label, type :params. demultiplexing , extrapars : demux_pars[params. demultiplexing], models : demux_models )
@@ -467,6 +474,7 @@ workflow {
467474
468475 switch (params. demultiplexing) {
469476 case " seqtagger" :
477+ case " seqtagger-trna" :
470478 outbc = BASECALL (pod5_4_analysis)
471479 demux = DEMULTIPLEX (pod5_4_analysis, outbc. basecalled_fastq)
472480 demufq = demux. demultiplexed_fastq
0 commit comments