iro/worker.py
changeset 41 02e9b54ef4f0
parent 23 0180b538ed74
child 42 1a9f191389a4
--- 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))