Show More
@@ -195,7 +195,7 b' class AsyncResult(object):' | |||
|
195 | 195 | def abort(self): |
|
196 | 196 | """abort my tasks.""" |
|
197 | 197 | assert not self.ready(), "Can't abort, I am already done!" |
|
198 | return self.client.abort(self.msg_ids, targets=self._targets, block=True) | |
|
198 | return self._client.abort(self.msg_ids, targets=self._targets, block=True) | |
|
199 | 199 | |
|
200 | 200 | @property |
|
201 | 201 | def sent(self): |
@@ -19,6 +19,7 b' Authors:' | |||
|
19 | 19 | |
|
20 | 20 | from IPython.parallel.error import TimeoutError |
|
21 | 21 | |
|
22 | from IPython.parallel import error | |
|
22 | 23 | from IPython.parallel.tests import add_engines |
|
23 | 24 | from .clienttest import ClusterTestCase |
|
24 | 25 | |
@@ -32,7 +33,8 b' def wait(n):' | |||
|
32 | 33 | |
|
33 | 34 | class AsyncResultTest(ClusterTestCase): |
|
34 | 35 | |
|
35 | def test_single_result(self): | |
|
36 | def test_single_result_view(self): | |
|
37 | """various one-target views get the right value for single_result""" | |
|
36 | 38 | eid = self.client.ids[-1] |
|
37 | 39 | ar = self.client[eid].apply_async(lambda : 42) |
|
38 | 40 | self.assertEquals(ar.get(), 42) |
@@ -112,4 +114,12 b' class AsyncResultTest(ClusterTestCase):' | |||
|
112 | 114 | self.assertTrue(isinstance(ar.engine_id, int)) |
|
113 | 115 | self.assertEquals(ar.engine_id, ar['engine_id']) |
|
114 | 116 | |
|
117 | def test_abort(self): | |
|
118 | e = self.client[-1] | |
|
119 | ar = e.execute('import time; time.sleep(1)', block=False) | |
|
120 | ar2 = e.apply_async(lambda : 2) | |
|
121 | ar2.abort() | |
|
122 | self.assertRaises(error.TaskAborted, ar2.get) | |
|
123 | ar.get() | |
|
124 | ||
|
115 | 125 |
General Comments 0
You need to be logged in to leave comments.
Login now