Revision e6e17529
b/lib/jqueue.py | ||
---|---|---|
1104 | 1104 |
""" |
1105 | 1105 |
op = opctx.op |
1106 | 1106 |
|
1107 |
assert op.status == constants.OP_STATUS_WAITING |
|
1107 |
assert op.status in (constants.OP_STATUS_WAITING, |
|
1108 |
constants.OP_STATUS_CANCELING) |
|
1109 |
|
|
1110 |
# The very last check if the job was cancelled before trying to execute |
|
1111 |
if op.status == constants.OP_STATUS_CANCELING: |
|
1112 |
return (constants.OP_STATUS_CANCELING, None) |
|
1108 | 1113 |
|
1109 | 1114 |
timeout = opctx.GetNextLockTimeout() |
1110 | 1115 |
|
Also available in: Unified diff