Show More
@@ -182,6 +182,9 b' class ParallelFunction(RemoteFunction):' | |||
|
182 | 182 | # 'all' is lazily evaluated at execution time, which is now: |
|
183 | 183 | if targets == 'all': |
|
184 | 184 | targets = client._build_targets(targets)[1] |
|
185 | elif isinstance(targets, int): | |
|
186 | # single-engine view, targets must be iterable | |
|
187 | targets = [targets] | |
|
185 | 188 | nparts = len(targets) |
|
186 | 189 | |
|
187 | 190 | msg_ids = [] |
@@ -534,4 +534,10 b' class TestView(ClusterTestCase):' | |||
|
534 | 534 | echo = lambda x:x |
|
535 | 535 | self.assertRaisesRemote(NameError, v.apply_sync, echo, r) |
|
536 | 536 | |
|
537 | def test_single_engine_map(self): | |
|
538 | e0 = self.client[self.client.ids[0]] | |
|
539 | r = range(5) | |
|
540 | check = [ -1*i for i in r ] | |
|
541 | result = e0.map_sync(lambda x: -1*x, r) | |
|
542 | self.assertEquals(result, check) | |
|
537 | 543 |
General Comments 0
You need to be logged in to leave comments.
Login now