diff -r 02e9b54ef4f0 -r 1a9f191389a4 iro/tests/testWorker.py --- 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()