--- a/iro/worker.py Wed Mar 21 19:41:55 2012 +0100
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,28 +0,0 @@
-# -*- coding: utf-8 -*-
-# Worker code
-
-from multiprocessing import Process
-import logging
-logger = logging.getLogger("iro.worker")
-
-class Worker(Process):
- def __init__(self,queue):
- Process.__init__(self)
- self.queue=queue
-
- def run(self):
- logger.info('Workerprocess läuft nun...')
- indifier=0
- while 1:
- job=self.queue.get()
- if job is None:
- break # reached end of queue
- indifier+=1
- logger.info('ein neuer Job(%d)' %(indifier))
- try:
- job.start(indifier)
- logger.info('Job(%d) fertig ;)'%(indifier))
- except:
- job.setStatus("error")
- logger.exception('Job(%d) fehlgeschlagen :('%(indifier))
-