m26508134
/
docklet
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix a bug of jobmgr

This commit is contained in:
zhuyj17 2018-11-11 23:26:13 +08:00
parent 329761d671
commit 8ef456b246
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/master/jobmgr.py
View File

@ -62,7 +62,7 @@ class BatchJob(object):
task_name = self.user + '_' + self.job_id + '_' + task_idx task_name = self.user + '_' + self.job_id + '_' + task_idx
return task_name, self.raw_job_info["tasks"][task_idx] return task_name, self.raw_job_info["tasks"][task_idx]
return '', None return '', None
# a task has finished # a task has finished
def finish_task(self, task_idx): def finish_task(self, task_idx):
pass pass
@ -137,7 +137,7 @@ class JobMgr(threading.Thread):
if not task_info: if not task_info:
return False return False
else: else:
task_priority = self.job_priority task_priority = job.job_priority
self.taskmgr.add_task(job.user, task_name, task_info, task_priority) self.taskmgr.add_task(job.user, task_name, task_info, task_priority)
return True return True
@ -155,4 +155,3 @@ class JobMgr(threading.Thread):
# a task has finished # a task has finished
def report(self, task): def report(self, task):
pass pass