Commit 111044fe authored by Wei Guo's avatar Wei Guo
Browse files

enforce summary, add timelimit per task

parent 374cfcad
__version__ = '1.0.0a5'
__version__ = '1.0.0a6'
......@@ -173,8 +173,9 @@ class SrunExecutor(BaseExecutor):
def run_cmd(self, cmd, stderr_file, stdout_file):
cpus_per_task = self.params.vals['cpus_per_task']
srun_cmd = "srun --exclusive -N1 -n1 --cpus-per-task=%d --distribution=cyclic %s" % (
cpus_per_task, cmd['__command']['value'])
timelimit_per_task = self.params.vals['timelimit_per_task']
srun_cmd = "srun --exclusive -N1 -n1 --cpus-per-task=%d --distribution=cyclic -t %s %s" % (
cpus_per_task, timelimit_per_task, cmd['__command']['value'])
ret = call(srun_cmd, shell=True, stderr=stderr_file,
stdout=stdout_file, env=os.environ)
......
......@@ -48,11 +48,18 @@
"description":"Number of CPUs required by each task. ",
"name":"cpus_per_task"
},
"timelimit_per_task":{
"type":"string",
"minLength":1,
"title":"Time Limit Per Task/Command",
"description":"Time limit for each command to finish.",
"name":"timelimit_per_task"
},
"time_limit":{
"type":"string",
"minLength":1,
"title":"Time Limit",
"description":"Time limit for the entire run.",
"description":"Time limit for the entire submitted job.",
"name":"time_limit"
},
"summary":{
......@@ -116,6 +123,7 @@
"cpus_per_task",
"time_limit",
"parameters",
"summary",
],
"definitions":{
"int_range":{
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment