# -*- coding: utf-8 -*-

# Worker code

from multiprocessing import Process

import logging

logger = logging.getLogger("iro.worker")

class Worker(Process):

    def __init__(self,queue):

        Process.__init__(self)

        self.queue=queue

    def run(self):

        id=0

        while 1:

            job=self.queue.get()

            if job is None:

                break # reached end of queue

            id+=1

            logger.info('ein neuer Job(%d)' %(id))

            try:

                job.start(id)

                logger.info('Job(%d) fertig ;)'%(id))

            except:

                job.setStatus("error")

                logger.exception('Job(%d) fehlgeschlagen :('%(id))