iro/worker.py
changeset 45 4bde195af39f
parent 42 1a9f191389a4
child 48 32763e344d3b
--- 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))
+