@@ -74,16 +74,14 @@ class BsubExecutor(private val workflowConfig: WorkflowConfig) : LocallyDirected
74
74
75
75
val mem = taskConfig.bsub?.mem ? : taskRunContexts.map { it.memory }.maxBy { it?.bytes ? : - 1 }
76
76
val cpus = taskConfig.bsub?.cpus ? : taskRunContexts.map { it.cpus }.maxBy { it ? : - 1 }
77
- val timePerTask = taskConfig.bsub?.time ? : taskRunContexts.map { it.cpus }.maxBy { it ? : - 1 }
78
- val time = if (timePerTask != null ) timePerTask * taskRunContexts.size else null
79
77
val gpus = taskConfig.bsub?.gpu ? : " \"\" "
80
78
81
79
appendBsubParam(bsubScript, " J" , bsubWorkflowJobName)
82
80
appendBsubParam(bsubScript, " o" , logsPath.resolve(" out.txt" ))
83
81
appendBsubParam(bsubScript, " e" , logsPath.resolve(" err.txt" ))
84
82
appendBsubParam(bsubScript, " R" , taskConfig.bsub?.rUsage)
85
83
appendBsubParam(bsubScript, " n" , cpus)
86
- appendBsubParam(bsubScript, " W" , time)
84
+ appendBsubParam(bsubScript, " W" , taskConfig.bsub?. time)
87
85
appendBsubParam(bsubScript, " q" , taskConfig.bsub?.partition)
88
86
appendBsubParam(bsubScript, " gpu" , gpus)
89
87
for ((argName, argVal) in taskConfig.bsub?.sbatchArgs ? : mapOf ()) {
0 commit comments