# -*- 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):
        logger.info('Workerprocess läuft nun...')
        indifier=0
        while 1:
            job=self.queue.get()
            if job is None:
                break # reached end of queue
            indifier+=1
            logger.info('ein neuer Job(%d)' %(indifier))
            try:
                job.start(indifier)
                logger.info('Job(%d) fertig ;)'%(indifier))
            except:
                job.setStatus("error")
                logger.exception('Job(%d) fehlgeschlagen :('%(indifier))