We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
null
1 parent 4f7b7ab commit 0d9350dCopy full SHA for 0d9350d
modules/nextflow/src/main/groovy/nextflow/processor/LocalPollingMonitor.groovy
@@ -225,10 +225,13 @@ class LocalPollingMonitor extends TaskPollingMonitor {
225
*/
226
@Override
227
protected void submit(TaskHandler handler) {
228
+ final taskGpus = gpus(handler)
229
+ if ( taskGpus > 0 ) {
230
+ ((LocalTaskHandler) handler).gpuSlots = availGpus.acquire(taskGpus)
231
+ }
232
super.submit(handler)
233
availCpus -= cpus(handler)
234
availMemory -= mem(handler)
- ((LocalTaskHandler) handler).gpuSlots = availGpus.acquire(gpus(handler))
235
}
236
237
/**
0 commit comments