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: |
|
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