iro/worker.py
branchdevel
changeset 240 3406d3bf05d4
parent 239 4cf5e664c847
child 241 546316b0b09c
--- 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))
-