From 8ef456b2465f53afa5e61a14ff1faa01a7ddd524 Mon Sep 17 00:00:00 2001
From: zhuyj17 <firmlyzhu@163.com>
Date: Sun, 11 Nov 2018 23:26:13 +0800
Subject: [PATCH] Fix a bug of jobmgr

---
 src/master/jobmgr.py | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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