Synnefo » snf-ganeti

JOBQUEUE_THREADS = 5

class _QueuedOpCode(object):

  """Encasulates an opcode object.

    self.status = constants.OP_STATUS_QUEUED

    self.result = None

    self.log = []

  @classmethod

  def Restore(cls, state):

    obj.status = state["status"]

    obj.result = state["result"]

    obj.log = state["log"]

    return obj

  def Serialize(self):

      "status": self.status,

      "result": self.result,

      "log": self.log,

      }

              job.run_op_index = idx

              op.status = constants.OP_STATUS_RUNNING

              op.result = None

              queue.UpdateJobUnlocked(job)

              input_opcode = op.input

            try:

              op.status = constants.OP_STATUS_SUCCESS

              op.result = result

              queue.UpdateJobUnlocked(job)

            finally:

              queue.release()

              try:

                op.status = constants.OP_STATUS_ERROR

                op.result = str(err)

                logging.debug("Op %s/%s: Error in %s", idx + 1, count, op)

              finally:

                queue.UpdateJobUnlocked(job)