# -*- 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...')
        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()
                logger.info('Job(%d) fertig ;)'%(id))
            except:
                job.setStatus("error")
                logger.exception('Job(%d) fehlgeschlagen :('%(id))