Show More
@@ -89,7 +89,6 b' def sync_view_results(f, self, *args, **kwargs):' | |||
|
89 | 89 | view = self.view |
|
90 | 90 | if view._in_sync_results: |
|
91 | 91 | return f(self, *args, **kwargs) |
|
92 | print 'in sync results', f | |
|
93 | 92 | view._in_sync_results = True |
|
94 | 93 | try: |
|
95 | 94 | ret = f(self, *args, **kwargs) |
@@ -63,8 +63,7 b' def setup():' | |||
|
63 | 63 | tic = time.time() |
|
64 | 64 | while not os.path.exists(engine_json) or not os.path.exists(client_json): |
|
65 | 65 | if cp.poll() is not None: |
|
66 | print cp.poll() | |
|
67 | raise RuntimeError("The test controller failed to start.") | |
|
66 | raise RuntimeError("The test controller exited with status %s" % cp.poll()) | |
|
68 | 67 | elif time.time()-tic > 15: |
|
69 | 68 | raise RuntimeError("Timeout waiting for the test controller to start.") |
|
70 | 69 | time.sleep(0.1) |
@@ -172,7 +172,6 b' class TestClient(ClusterTestCase):' | |||
|
172 | 172 | # give the monitor time to notice the message |
|
173 | 173 | time.sleep(.25) |
|
174 | 174 | ahr = self.client.get_result(ar.msg_ids[0]) |
|
175 | print ar.get(), ahr.get(), ar._single_result, ahr._single_result | |
|
176 | 175 | self.assertTrue(isinstance(ahr, AsyncHubResult)) |
|
177 | 176 | self.assertEqual(ahr.get().pyout, ar.get().pyout) |
|
178 | 177 | ar2 = self.client.get_result(ar.msg_ids[0]) |
General Comments 0
You need to be logged in to leave comments.
Login now