--- a/iro/worker.py Fri Nov 27 01:07:44 2009 +0100
+++ b/iro/worker.py Fri Nov 27 01:09:34 2009 +0100
@@ -3,6 +3,7 @@
from multiprocessing import Process
import logging
+logger = logging.getLogger("iro.worker")
import time
class Worker(Process):
@@ -11,16 +12,16 @@
self.queue=queue
def run(self):
- logging.info('Worker thread läuft nun...')
+ logger.info('Worker thread läuft nun...')
id=0
while 1:
job=self.queue.get()
if job is None:
break # reached end of queue
id+=1
- logging.info('ein neuer Job(%d)' %(id))
+ logger.info('ein neuer Job(%d)' %(id))
try:
job.start(id)
- logging.info('Job(%d) fertig ;)'%(id))
+ logger.info('Job(%d) fertig ;)'%(id))
except:
- logging.exception('Job(%d) fehlgeschlagen :('%(id))
+ logger.exception('Job(%d) fehlgeschlagen :('%(id))