Synnefo » snf-ganeti

    """

    logging.debug("Worker %s processing job %s",

                  self.worker_id, job.id)

    queue = job.queue

    try:

      try:

class _JobQueueWorkerPool(workerpool.WorkerPool):

    super(_JobQueueWorkerPool, self).__init__(JOBQUEUE_THREADS,

                                              _JobQueueWorker)

class JobQueue(object):

  _RE_JOB_FILE = re.compile(r"^job-(%s)$" % constants.JOB_ID_TEMPLATE)

  def __init__(self, context):

    self._memcache = {}

    self._my_hostname = utils.HostInfo().name

                                      " file")

    # Setup worker pool

    # We need to lock here because WorkerPool.AddTask() may start a job while

    # we're still doing our work.