##// END OF EJS Templates
improve reliability of occasionally failing parallel tests
MinRK -
Show More
@@ -228,6 +228,8 b' class TestClient(ClusterTestCase):'
228 v = self.client.load_balanced_view()
228 v = self.client.load_balanced_view()
229 ar = v.apply_async(f)
229 ar = v.apply_async(f)
230 r1 = ar.get(1)
230 r1 = ar.get(1)
231 # give the Hub a chance to notice:
232 time.sleep(0.5)
231 ahr = self.client.resubmit(ar.msg_ids)
233 ahr = self.client.resubmit(ar.msg_ids)
232 r2 = ahr.get(1)
234 r2 = ahr.get(1)
233 self.assertFalse(r1 == r2)
235 self.assertFalse(r1 == r2)
@@ -59,6 +59,7 b' class TestLoadBalancedView(ClusterTestCase):'
59 def test_abort(self):
59 def test_abort(self):
60 view = self.view
60 view = self.view
61 ar = self.client[:].apply_async(time.sleep, .5)
61 ar = self.client[:].apply_async(time.sleep, .5)
62 ar = self.client[:].apply_async(time.sleep, .5)
62 ar2 = view.apply_async(lambda : 2)
63 ar2 = view.apply_async(lambda : 2)
63 ar3 = view.apply_async(lambda : 3)
64 ar3 = view.apply_async(lambda : 3)
64 view.abort(ar2)
65 view.abort(ar2)
@@ -319,7 +319,7 b' class TestView(ClusterTestCase):'
319 ip.magic_px('print a')
319 ip.magic_px('print a')
320 sys.stdout = savestdout
320 sys.stdout = savestdout
321 buf = sio.getvalue()
321 buf = sio.getvalue()
322 self.assertTrue('[stdout:%i]'%v.targets in buf)
322 self.assertTrue('[stdout:' in buf, buf)
323 self.assertTrue(buf.rstrip().endswith('10'))
323 self.assertTrue(buf.rstrip().endswith('10'))
324 self.assertRaisesRemote(ZeroDivisionError, ip.magic_px, '1/0')
324 self.assertRaisesRemote(ZeroDivisionError, ip.magic_px, '1/0')
325
325
General Comments 0
You need to be logged in to leave comments. Login now