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/<ipython-input-34-8531eb3d26fb> in <module>()
----> 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/<ipython-input-35-1779b888dcf5> in <module>()
----> 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/<string> 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/<string> 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/<ipython-input-36-25710ae84c54> in <module>()
----> 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