--- a/iro/worker.py Tue Oct 05 03:24:01 2010 +0200
+++ b/iro/worker.py Wed Oct 06 04:28:19 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,8 @@
id+=1
logger.info('ein neuer Job(%d)' %(id))
try:
- job.start(id)
+ job.start()
+
logger.info('Job(%d) fertig ;)'%(id))
except:
logger.exception('Job(%d) fehlgeschlagen :('%(id))