On Thu, May 21, 2015 at 06:39:54PM +0200, 'Klaus Aehlig' via ganeti-devel wrote:
Signed-off-by: Klaus Aehlig <[email protected]> --- lib/jqueue/exec.py | 4 ++++ 1 file changed, 4 insertions(+)diff --git a/lib/jqueue/exec.py b/lib/jqueue/exec.py index cd597f9..d66fc82 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) + job = context.jobqueue.SafeLoadJobFromDisk(job_id, False) + proc = _JobProcessor(context.jobqueue, execfun, job) 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
LGTM, thanks
