Synnefo » snf-ganeti

  @ivar id: the job ID

  @type ops: list

  @ivar ops: the list of _QueuedOpCode that constitute the job

  @type log_serial: int

  @ivar log_serial: holds the index for the next log entry

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

  @ivar change: a Condition variable we use for waiting for job changes

  """

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

               "lock_status", "change",

               "__weakref__"]

    self.queue = queue

    self.id = job_id

    self.ops = [_QueuedOpCode(op) for op in ops]

    self.log_serial = 0

    self.received_timestamp = TimeStampNow()

    self.start_timestamp = None

    obj = _QueuedJob.__new__(cls)

    obj.queue = queue

    obj.id = state["id"]

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

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

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

    return {

      "id": self.id,

      "ops": [op.Serialize() for op in self.ops],

      "start_timestamp": self.start_timestamp,

      "end_timestamp": self.end_timestamp,

      "received_timestamp": self.received_timestamp,

              if op.status == constants.OP_STATUS_CANCELED:

                raise CancelJob()

              assert op.status == constants.OP_STATUS_QUEUED

              op.status = constants.OP_STATUS_WAITLOCK

              op.result = None

              op.start_timestamp = TimeStampNow()

      try:

        try:

          job.lock_status = None

          job.end_timestamp = TimeStampNow()

          queue.UpdateJobUnlocked(job)

        finally: