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