--- 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))