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