--- a/iro/tests/testWorker.py	Wed Oct 06 04:28:19 2010 +0200
+++ b/iro/tests/testWorker.py	Wed Oct 06 04:31:54 2010 +0200
@@ -32,9 +32,17 @@
             record.exc_info=record.exc_info[:-1]                                              
         self.buffer.append(record.__dict__)
 
+
+class BadJob(Job):
+    def start(self):
+        Job.start(self)
+        raise Exception("Error")
+
+#einen Manager anlegen, der Job und eine Liste anbietet
 class MyManager(BaseManager):
     pass
 MyManager.register('Job', Job) 
+MyManager.register('BadJob', BadJob) 
 MyManager.register('list', list, ListProxy)
 
 class TestWorker(unittest.TestCase):
@@ -99,6 +107,24 @@
                  (20,'ein neuer Job(1)'),
                  (20,'Job(1) fertig ;)')])
 
+    def testBadJob(self):
+        '''einen Job verarbeiten, der fehlschlägt'''
+        job=self.manager.BadJob(None,None,"test")
+        self.assertEqual(job.getStatus(),"init")
+        self.queue.put(job)
+        sleep(.1)
+        self.stop()
+        self.assertEqual(job.getStatus(),"error")
+        print self.buffer
+        self.assertEqual([(l['levelno'],l['msg']) for l in self.buffer if l['name']=="iro.worker"],
+                [(20,'Workerprocess läuft nun...'),
+                 (20,'ein neuer Job(1)'),
+                 (40,'Job(1) fehlgeschlagen :(')])
+        error=Exception('Error')
+        self.assertEqual(self.buffer[-1]['exc_info'][0],type(error))
+        self.assertEqual(str(self.buffer[-1]['exc_info'][1]),str(error))
+
+
 
 if __name__ == "__main__":
     unittest.main()