diff -r 4cf5e664c847 -r 3406d3bf05d4 iro/worker.py --- a/iro/worker.py Wed Mar 21 19:41:55 2012 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,28 +0,0 @@ -# -*- 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)) -