[PATCH master] After modifying a job, also reset the process

['Klaus Aehlig' via ganeti-devel]

Signed-off-by: Klaus Aehlig <aeh...@google.com>
---
 lib/jqueue/exec.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/lib/jqueue/exec.py b/lib/jqueue/exec.py
index cd597f9..bf4340d 100644
--- a/lib/jqueue/exec.py
+++ b/lib/jqueue/exec.py
@@ -120,6 +120,8 @@ def main():
       if cancel[0]:
         logging.debug("Got cancel request, cancelling job %d", job_id)
         r = context.jobqueue.CancelJob(job_id)
+        job = context.jobqueue.SafeLoadJobFromDisk(job_id, False)
+        proc = _JobProcessor(context.jobqueue, execfun, job)
         logging.debug("CancelJob result for job %d: %s", job_id, r)
         cancel[0] = False
       if prio_change[0]:
@@ -130,6 +132,8 @@ def main():
           utils.RemoveFile(fname)
           logging.debug("Changing priority of job %d to %d", job_id, new_prio)
           r = context.jobqueue.ChangeJobPriority(job_id, new_prio)
+          proc = _JobProcessor(context.jobqueue, execfun, job)
+          job = context.jobqueue.SafeLoadJobFromDisk(job_id, False)
           logging.debug("Result of changing priority of %d to %d: %s", job_id,
                         new_prio, r)
         except Exception: # pylint: disable=W0703
-- 
2.2.0.rc0.207.ga3a616c