Synnefo » snf-ganeti » ganeti-local

  @ivar received_timestamp: the timestamp for when the job was received

  @ivar start_timestmap: the timestamp for start of execution

  @ivar end_timestamp: the timestamp for end of execution

  """

  # pylint: disable-msg=W0212

  __slots__ = ["queue", "id", "ops", "log_serial",

               "received_timestamp", "start_timestamp", "end_timestamp",

               "__weakref__"]

  def __init__(self, queue, job_id, ops):

    self.start_timestamp = None

    self.end_timestamp = None

  def __repr__(self):

    status = ["%s.%s" % (self.__class__.__module__, self.__class__.__name__),

              "id=%s" % self.id,

    obj.start_timestamp = state.get("start_timestamp", None)

    obj.end_timestamp = state.get("end_timestamp", None)

    obj.ops = []

    obj.log_serial = 0

    for op_state in state["ops"]:

        row.append(self.start_timestamp)

      elif fname == "end_ts":

        row.append(self.end_timestamp)

      elif fname == "summary":

        row.append([op.input.Summary() for op in self.ops])

      else:

    Processor.ExecOpCode) set to OP_STATUS_WAITLOCK.

    """

    assert self._op.status in (constants.OP_STATUS_WAITLOCK,

                               constants.OP_STATUS_CANCELING)

    # Cancel here if we were asked to

    self._CheckCancel()

    logging.debug("Opcode is now running")

    self._op.status = constants.OP_STATUS_RUNNING

    self._op.exec_timestamp = TimeStampNow()

    assert self._op.status in (constants.OP_STATUS_WAITLOCK,

                               constants.OP_STATUS_CANCELING)

    # Cancel here if we were asked to

    self._CheckCancel()

              op.result = result

              op.end_timestamp = TimeStampNow()

              if idx == count - 1:

                job.end_timestamp = TimeStampNow()

                # Consistency check

                                  errors.GetEncodedError(i.result)

                                  for i in job.ops[idx:])

              finally:

                job.end_timestamp = TimeStampNow()

                queue.UpdateJobUnlocked(job)

            finally:

        try:

          job.MarkUnfinishedOps(constants.OP_STATUS_CANCELED,

                                "Job canceled by request")

          job.end_timestamp = TimeStampNow()

          queue.UpdateJobUnlocked(job)

        finally: