Commit ed21712b authored by Iustin Pop's avatar Iustin Pop
Browse files

Fix an error path in job queue worker's RunTask



In case the job fails, we try to set the job's run_op_idx to -1.
However, this is a wrong variable, which wasn't detected until the
__slots__ addition. The correct variable is run_op_index.
Signed-off-by: default avatarIustin Pop <iustin@google.com>
Reviewed-by: default avatarGuido Trotter <ultrotter@google.com>
parent 66d895a8
......@@ -455,7 +455,7 @@ class _JobQueueWorker(workerpool.BaseWorker):
queue.acquire()
try:
try:
job.run_op_idx = -1
job.run_op_index = -1
job.end_timestamp = TimeStampNow()
queue.UpdateJobUnlocked(job)
finally:
......
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