View difference between Paste ID: EkxAArSw and
SHOW:
|
|
- or go back to the newest paste.
1 | - | |
1 | + | In [27]: c = Client() |
2 | ||
3 | In [28]: dview=c[:] | |
4 | ||
5 | In [29]: ar=dview.apply_async(sleep,10) | |
6 | ||
7 | In [30]: c.shutdown(0) | |
8 | ||
9 | In [31]: ar.get() | |
10 | Out[31]: [None, None, None, None, None, None, None, None, None, None] | |
11 | ||
12 | In [32]: ar=dview.apply_async(sleep,10) | |
13 | ||
14 | In [33]: c.shutdown(1) | |
15 | ||
16 | In [34]: ar.get() | |
17 | --------------------------------------------------------------------------- | |
18 | CompositeError Traceback (most recent call last) | |
19 | /Users/maarten/<ipython-input-34-8531eb3d26fb> in <module>() | |
20 | ----> 1 ar.get() | |
21 | ||
22 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/asyncresult.pyc in get(self, timeout) | |
23 | 101 return self._result | |
24 | 102 else: | |
25 | --> 103 raise self._exception | |
26 | 104 else: | |
27 | 105 raise error.TimeoutError("Result not ready.") | |
28 | ||
29 | CompositeError: one or more exceptions from call to method: sleep | |
30 | [Engine Exception]EngineError: Engine 0 died while running task '85bef637-5682-48f0-92c0-5cf9652db4ba' | |
31 | ||
32 | In [35]: ar=dview.apply_async(sleep,10) | |
33 | --------------------------------------------------------------------------- | |
34 | KeyError Traceback (most recent call last) | |
35 | /Users/maarten/<ipython-input-35-1779b888dcf5> in <module>() | |
36 | ----> 1 ar=dview.apply_async(sleep,10) | |
37 | ||
38 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in apply_async(self, f, *args, **kwargs) | |
39 | 214 returns AsyncResult | |
40 | 215 """ | |
41 | --> 216 return self._really_apply(f, args, kwargs, block=False) | |
42 | 217 | |
43 | 218 @spin_after | |
44 | ||
45 | /Users/maarten/<string> in _really_apply(self, f, args, kwargs, targets, block, track) | |
46 | ||
47 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in sync_results(f, self, *args, **kwargs) | |
48 | 55 def sync_results(f, self, *args, **kwargs): | |
49 | 56 """sync relevant results from self.client to our results attribute.""" | |
50 | ---> 57 ret = f(self, *args, **kwargs) | |
51 | 58 delta = self.outstanding.difference(self.client.outstanding) | |
52 | 59 completed = self.outstanding.intersection(delta) | |
53 | ||
54 | /Users/maarten/<string> in _really_apply(self, f, args, kwargs, targets, block, track) | |
55 | ||
56 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in save_ids(f, self, *args, **kwargs) | |
57 | 44 n_previous = len(self.client.history) | |
58 | 45 try: | |
59 | ---> 46 ret = f(self, *args, **kwargs) | |
60 | 47 finally: | |
61 | 48 nmsgs = len(self.client.history) - n_previous | |
62 | ||
63 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in _really_apply(self, f, args, kwargs, targets, block, track) | |
64 | 516 targets = self.targets if targets is None else targets | |
65 | 517 | |
66 | --> 518 _idents = self.client._build_targets(targets)[0] | |
67 | 519 msg_ids = [] | |
68 | 520 trackers = [] | |
69 | ||
70 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in _build_targets(self, targets) | |
71 | 464 raise TypeError("targets by int/slice/collection of ints only, not %s"%(type(targets))) | |
72 | 465 | |
73 | --> 466 return [util.asbytes(self._engines[t]) for t in targets], list(targets) | |
74 | 467 | |
75 | 468 def _connect(self, sshserver, ssh_kwargs, timeout): | |
76 | ||
77 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/util.pyc in __getitem__(self, key) | |
78 | 79 return dict.__getitem__(self, key) | |
79 | 80 except KeyError: | |
80 | ---> 81 return self._reverse[key] | |
81 | 82 | |
82 | 83 def __setitem__(self, key, value): | |
83 | ||
84 | KeyError: 0 | |
85 | ||
86 | In [36]: dview=c[:] | |
87 | --------------------------------------------------------------------------- | |
88 | IndexError Traceback (most recent call last) | |
89 | /Users/maarten/<ipython-input-36-25710ae84c54> in <module>() | |
90 | ----> 1 dview=c[:] | |
91 | ||
92 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in __getitem__(self, key) | |
93 | 766 raise TypeError("key by int/slice/iterable of ints only, not %s"%(type(key))) | |
94 | 767 else: | |
95 | --> 768 return self.direct_view(key) | |
96 | 769 | |
97 | 770 #-------------------------------------------------------------------------- | |
98 | ||
99 | ||
100 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in direct_view(self, targets) | |
101 | 1042 """ | |
102 | 1043 single = isinstance(targets, int) | |
103 | -> 1044 targets = self._build_targets(targets)[1] | |
104 | 1045 if single: | |
105 | 1046 targets = targets[0] | |
106 | ||
107 | /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in _build_targets(self, targets) | |
108 | 459 indices = range(len(self._ids))[targets] | |
109 | 460 ids = self.ids | |
110 | --> 461 targets = [ ids[i] for i in indices ] | |
111 | 462 | |
112 | 463 if not isinstance(targets, (tuple, list, xrange)): | |
113 | ||
114 | IndexError: list index out of range |