Synnefo » snf-ganeti » ganeti-local

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

  """

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

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

               "lock_status", "change",

  """The actual job workers.

  """

    """Job executor.

    This functions processes a job. It is closely tied to the _QueuedJob and

  """

  def wrapper(self, *args, **kwargs):

    assert self._queue_lock is not None, "Queue should be open"

    return fn(self, *args, **kwargs)

  return wrapper

    try:

      job = _QueuedJob.Restore(self, data)

      new_path = self._GetArchivedJobPath(job_id)

      if filepath == new_path:

        # job already archived (future case)