iro/worker.py
changeset 20 0d7ffb9b2c7f
parent 0 a3b6e531f0d2
child 23 0180b538ed74
--- a/iro/worker.py	Mon Nov 23 00:18:04 2009 +0100
+++ b/iro/worker.py	Tue Nov 24 02:02:41 2009 +0100
@@ -2,6 +2,7 @@
 # Worker code
 
 from multiprocessing import Process
+import logging
 import time
 
 class Worker(Process):
@@ -10,8 +11,16 @@
         self.queue=queue
         
     def run(self):
+        logging.info('Worker thread läuft nun...')
+        id=0
         while 1:
             job=self.queue.get()
             if job is None:
                 break # reached end of queue
-            job.start()
+            id+=1
+            logging.info('ein neuer Job(%d)' %(id))
+            try:
+                job.start(id)
+                logging.info('Job(%d) fertig ;)'%(id))
+            except:
+                logging.exception('Job(%d) fehlgeschlagen :('%(id))