In [27]: c = Client() In [28]: dview=c[:] In [29]: ar=dview.apply_async(sleep,10) In [30]: c.shutdown(0) In [31]: ar.get() Out[31]: [None, None, None, None, None, None, None, None, None, None] In [32]: ar=dview.apply_async(sleep,10) In [33]: c.shutdown(1) In [34]: ar.get() --------------------------------------------------------------------------- CompositeError Traceback (most recent call last) /Users/maarten/ in () ----> 1 ar.get() /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/asyncresult.pyc in get(self, timeout) 101 return self._result 102 else: --> 103 raise self._exception 104 else: 105 raise error.TimeoutError("Result not ready.") CompositeError: one or more exceptions from call to method: sleep [Engine Exception]EngineError: Engine 0 died while running task '85bef637-5682-48f0-92c0-5cf9652db4ba' In [35]: ar=dview.apply_async(sleep,10) --------------------------------------------------------------------------- KeyError Traceback (most recent call last) /Users/maarten/ in () ----> 1 ar=dview.apply_async(sleep,10) /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in apply_async(self, f, *args, **kwargs) 214 returns AsyncResult 215 """ --> 216 return self._really_apply(f, args, kwargs, block=False) 217 218 @spin_after /Users/maarten/ in _really_apply(self, f, args, kwargs, targets, block, track) /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in sync_results(f, self, *args, **kwargs) 55 def sync_results(f, self, *args, **kwargs): 56 """sync relevant results from self.client to our results attribute.""" ---> 57 ret = f(self, *args, **kwargs) 58 delta = self.outstanding.difference(self.client.outstanding) 59 completed = self.outstanding.intersection(delta) /Users/maarten/ in _really_apply(self, f, args, kwargs, targets, block, track) /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/view.pyc in save_ids(f, self, *args, **kwargs) 44 n_previous = len(self.client.history) 45 try: ---> 46 ret = f(self, *args, **kwargs) 47 finally: 48 nmsgs = len(self.client.history) - n_previous /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) 516 targets = self.targets if targets is None else targets 517 --> 518 _idents = self.client._build_targets(targets)[0] 519 msg_ids = [] 520 trackers = [] /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in _build_targets(self, targets) 464 raise TypeError("targets by int/slice/collection of ints only, not %s"%(type(targets))) 465 --> 466 return [util.asbytes(self._engines[t]) for t in targets], list(targets) 467 468 def _connect(self, sshserver, ssh_kwargs, timeout): /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/util.pyc in __getitem__(self, key) 79 return dict.__getitem__(self, key) 80 except KeyError: ---> 81 return self._reverse[key] 82 83 def __setitem__(self, key, value): KeyError: 0 In [36]: dview=c[:] --------------------------------------------------------------------------- IndexError Traceback (most recent call last) /Users/maarten/ in () ----> 1 dview=c[:] /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in __getitem__(self, key) 766 raise TypeError("key by int/slice/iterable of ints only, not %s"%(type(key))) 767 else: --> 768 return self.direct_view(key) 769 770 #-------------------------------------------------------------------------- /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in direct_view(self, targets) 1042 """ 1043 single = isinstance(targets, int) -> 1044 targets = self._build_targets(targets)[1] 1045 if single: 1046 targets = targets[0] /Library/Python/2.6/site-packages/ipython-0.11-py2.6.egg/IPython/parallel/client/client.pyc in _build_targets(self, targets) 459 indices = range(len(self._ids))[targets] 460 ids = self.ids --> 461 targets = [ ids[i] for i in indices ] 462 463 if not isinstance(targets, (tuple, list, xrange)): IndexError: list index out of range