diff -r e20909e61588 -r 4bde195af39f iro/worker.py --- a/iro/worker.py Mon Feb 08 01:35:19 2010 +0100 +++ b/iro/worker.py Wed Oct 06 04:42:23 2010 +0200 @@ -4,7 +4,6 @@ from multiprocessing import Process import logging logger = logging.getLogger("iro.worker") -import time class Worker(Process): def __init__(self,queue): @@ -12,7 +11,7 @@ self.queue=queue def run(self): - logger.info('Worker thread läuft nun...') + logger.info('Workerprocess läuft nun...') id=0 while 1: job=self.queue.get() @@ -21,7 +20,9 @@ id+=1 logger.info('ein neuer Job(%d)' %(id)) try: - job.start(id) + job.start() logger.info('Job(%d) fertig ;)'%(id)) except: + job.setStatus("error") logger.exception('Job(%d) fehlgeschlagen :('%(id)) +