Revision f6424741 lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
362 | 362 |
count = len(job.ops) |
363 | 363 |
for idx, op in enumerate(job.ops): |
364 | 364 |
op_summary = op.input.Summary() |
365 |
if op.status == constants.OP_STATUS_SUCCESS: |
|
366 |
# this is a job that was partially completed before master |
|
367 |
# daemon shutdown, so it can be expected that some opcodes |
|
368 |
# are already completed successfully (if any did error |
|
369 |
# out, then the whole job should have been aborted and not |
|
370 |
# resubmitted for processing) |
|
371 |
logging.info("Op %s/%s: opcode %s already processed, skipping", |
|
372 |
idx + 1, count, op_summary) |
|
373 |
continue |
|
365 | 374 |
try: |
366 | 375 |
logging.info("Op %s/%s: Starting opcode %s", idx + 1, count, |
367 | 376 |
op_summary) |
Also available in: Unified diff