kkonganti@0: process {
kkonganti@0:     publishDir = [
kkonganti@0:         path: { 
kkonganti@0:             "${task.process.tokenize(':')[-1].toLowerCase()}" == "multiqc" ?
kkonganti@0:                 "${params.output}${params.fs}${params.pipeline.toLowerCase()}-${task.process.tokenize(':')[-1].toLowerCase()}" :
kkonganti@0:                 "${params.output}${params.fs}${task.process.tokenize(':')[-1].toLowerCase()}"
kkonganti@0:         },
kkonganti@0:         mode: params.publish_dir_mode,
kkonganti@0:         overwrite: params.publish_dir_overwrite,
kkonganti@0:         saveAs: { filename -> filename =~ /^versions.yml|.+?_mqc.*/ ? null : filename }
kkonganti@0:     ]
kkonganti@0: 
kkonganti@0:     errorStrategy = {
kkonganti@0:         ![0].contains(task.exitStatus) ? dynamic_retry(task.attempt, 10) : 'finish'
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     maxRetries = 1
kkonganti@0:     resourceLabels = {[
kkonganti@0:         process: task.process,
kkonganti@0:         memoryRequested: task.memory.toString(),
kkonganti@0:         cpusRequested: task.cpus.toString()
kkonganti@0:     ]}
kkonganti@0: 
kkonganti@0:     withLabel: 'process_femto' {
kkonganti@0:         cpus = { 1 * task.attempt }
kkonganti@0:         memory = { 1.GB * task.attempt }
kkonganti@0:         time = { 1.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_pico' {
kkonganti@0:         cpus = { min_cpus(2) * task.attempt }
kkonganti@0:         memory = { 4.GB * task.attempt }
kkonganti@0:         time = { 2.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_nano' {
kkonganti@0:         cpus = { min_cpus(4) * task.attempt }
kkonganti@0:         memory = { 8.GB * task.attempt }
kkonganti@0:         time = { 4.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_micro' {
kkonganti@0:         cpus = { min_cpus(8) * task.attempt }
kkonganti@0:         memory = { 16.GB * task.attempt }
kkonganti@0:         time = { 8.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_only_mem_low' {
kkonganti@0:         cpus = { 1 * task.attempt }
kkonganti@0:         memory = { 60.GB * task.attempt }
kkonganti@0:         time = { 20.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_only_mem_medium' {
kkonganti@0:         cpus = { 1 * task.attempt }
kkonganti@0:         memory = { 100.GB * task.attempt }
kkonganti@0:         time = { 30.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_only_mem_high' {
kkonganti@0:         cpus = { 1 * task.attempt }
kkonganti@0:         memory = { 128.GB * task.attempt }
kkonganti@0:         time = { 60.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_low' {
kkonganti@0:         cpus = { min_cpus(10) * task.attempt }
kkonganti@0:         memory = { 60.GB * task.attempt }
kkonganti@0:         time = { 20.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_medium' {
kkonganti@0:         cpus = { min_cpus(10) * task.attempt }
kkonganti@0:         memory = { 100.GB * task.attempt }
kkonganti@0:         time = { 30.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_high' {
kkonganti@0:         cpus = { min_cpus(10) * task.attempt }
kkonganti@0:         memory = { 128.GB * task.attempt }
kkonganti@0:         time = { 60.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_higher' {
kkonganti@0:         cpus = { min_cpus(10) * task.attempt }
kkonganti@0:         memory = { 256.GB * task.attempt }
kkonganti@0:         time = { 60.h * task.attempt }
kkonganti@0:     }
kkonganti@0: 
kkonganti@0:     withLabel: 'process_gigantic' {
kkonganti@0:         cpus = { min_cpus(10) * task.attempt }
kkonganti@0:         memory = { 512.GB * task.attempt }
kkonganti@0:         time = { 60.h * task.attempt }
kkonganti@0:     }
kkonganti@0: }
kkonganti@0: 
kkonganti@0: if ( (params.input || params.metadata ) && params.pipeline ) {
kkonganti@0:     try {
kkonganti@0:         includeConfig "${params.workflowsconf}${params.fs}process${params.fs}${params.pipeline}.process.config"
kkonganti@0:     } catch (Exception e) {
kkonganti@0:         System.err.println('-'.multiply(params.linewidth) + "\n" +
kkonganti@0:             "\033[0;31m${params.cfsanpipename} - ERROR\033[0m\n" +
kkonganti@0:             '-'.multiply(params.linewidth) + "\n" + "\033[0;31mCould not load " +
kkonganti@0:             "default pipeline's process configuration. Please provide a pipeline \n" +
kkonganti@0:             "name using the --pipeline option.\n\033[0m" + '-'.multiply(params.linewidth) + "\n")
kkonganti@0:         System.exit(1)
kkonganti@0:     }
kkonganti@0: }
kkonganti@0: 
kkonganti@0: // Function will return after sleeping for some time. 
kkonganti@0: // Sleep time increases exponentially by task attempt.
kkonganti@0: def dynamic_retry(task_retry_num, factor_by) {
kkonganti@0:     // sleep(Math.pow(2, task_retry_num.toInteger()) * factor_by.toInteger() as long)
kkonganti@0:     sleep(Math.pow(1.27, task_retry_num.toInteger()) as long)
kkonganti@0:     return 'retry'
kkonganti@0: }
kkonganti@0: 
kkonganti@0: // Function that will adjust the minimum number of CPU
kkonganti@0: // cores depending as requested by the user.
kkonganti@0: def min_cpus(cores) {
kkonganti@0:     return Math.min(cores as int, "${params.max_cpus}" as int)
kkonganti@0: }