Revision 65548ed5 lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
255 | 255 |
finally: |
256 | 256 |
queue.acquire() |
257 | 257 |
try: |
258 |
job_id = job.id |
|
259 |
status = job.CalcStatus() |
|
258 |
try: |
|
259 |
job.run_op_idx = -1 |
|
260 |
queue.UpdateJobUnlocked(job) |
|
261 |
finally: |
|
262 |
job_id = job.id |
|
263 |
status = job.CalcStatus() |
|
260 | 264 |
finally: |
261 | 265 |
queue.release() |
262 | 266 |
logging.debug("Worker %s finished job %s, status = %s", |
Also available in: Unified diff