Commit 65548ed5 authored by Michael Hanselmann's avatar Michael Hanselmann
Browse files

jqueue: Reset run_op_idx after job is done

It can be confusing otherwise.

Reviewed-by: ultrotter
parent e17188f4
......@@ -255,8 +255,12 @@ class _JobQueueWorker(workerpool.BaseWorker):
finally:
queue.acquire()
try:
job_id = job.id
status = job.CalcStatus()
try:
job.run_op_idx = -1
queue.UpdateJobUnlocked(job)
finally:
job_id = job.id
status = job.CalcStatus()
finally:
queue.release()
logging.debug("Worker %s finished job %s, status = %s",
......
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