Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement