Skip to content

Commit 8eae428

Browse files
committed
moved closure to queue input
1 parent 88aa739 commit 8eae428

File tree

1 file changed

+27
-31
lines changed

1 file changed

+27
-31
lines changed

conf/cheaha.config

Lines changed: 27 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
11
// Prevent schemas warnings for profile parameters
22
validation {
33
ignoreParams = [
4-
'cheaha_scratch_dir',
5-
'cheaha_getQueues'
4+
'cheaha_scratch_dir'
65
]
76
}
87

@@ -27,33 +26,6 @@ singularity {
2726
runOptions = "--contain --workdir ${params.cheaha_scratch_dir} -B /scratch"
2827
}
2928

30-
params.cheaha_getQueues = { time, memory ->
31-
def queue_list = ["long"]
32-
33-
if (time <= 2.h) {
34-
queue_list.add("express")
35-
}
36-
37-
if (time <= 12.h) {
38-
queue_list.add("short")
39-
}
40-
41-
if (time <= 50.h) {
42-
queue_list.add("medium")
43-
}
44-
45-
if (memory >= 300.GB) {
46-
queue_list.add("largemem-long")
47-
48-
if (time <= 50.h) {
49-
queue_list.add("largemem")
50-
}
51-
}
52-
53-
return queue_list.join(",")
54-
}
55-
//Note .call() above did not resolve current warning for Nextflow plugin (for queue process below).
56-
5729
process {
5830
resourceLimits = [
5931
memory: 750.GB,
@@ -63,5 +35,29 @@ process {
6335
executor = 'slurm'
6436
maxRetries = 3
6537
beforeScript = 'module load Singularity/3.5.2-GCC-5.4.0-2.26'
66-
queue = { params.cheaha_getQueues( task.time, task.memory ) }
67-
}
38+
queue = {
39+
def queue_list = ["long"]
40+
41+
if (task.time <= 2.h) {
42+
queue_list.add("express")
43+
}
44+
45+
if (task.time <= 12.h) {
46+
queue_list.add("short")
47+
}
48+
49+
if (task.time <= 50.h) {
50+
queue_list.add("medium")
51+
}
52+
53+
if (task.memory >= 300.GB) {
54+
queue_list.add("largemem-long")
55+
56+
if (task.time <= 50.h) {
57+
queue_list.add("largemem")
58+
}
59+
}
60+
61+
return queue_list.join(",")
62+
}
63+
}

0 commit comments

Comments
 (0)