Synnefo » snf-ganeti

  @ivar start_timestmap: the timestamp for start of execution

  @ivar end_timestamp: the timestamp for end of execution

  @ivar lock_status: In-memory locking information for debugging

  """

  # pylint: disable-msg=W0212

    # In-memory attributes

    self.lock_status = None

  def __repr__(self):

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

              "id=%s" % self.id,

        obj.log_serial = max(obj.log_serial, log_entry[0])

      obj.ops.append(op)

    return obj

  def Serialize(self):

      self._job.log_serial += 1

      self._op.log.append((self._job.log_serial, timestamp, log_type, log_msg))

      self._queue.UpdateJobUnlocked(self._job, replicate=False)

    finally:

      self._queue.release()

    logging.debug("Writing job %s to %s", job.id, filename)

    self._UpdateJobQueueFile(filename, data, replicate)

  def WaitForJobChanges(self, job_id, fields, prev_job_info, prev_log_serial,

                        timeout):

    """Waits for changes in a job.