spacepaste

Paste details

reply | raw

  1.  
  2. import sys
  3. import twisted.internet.defer
  4. import twisted.internet.reactor
  5. import twisted.python.log
  7. print "Twisted version", twisted.version
  8. print "Python version", sys.version
  10. class ExceptionToRaise(Exception):
  11. pass
  13. exception_to_raise = ExceptionToRaise()
  15. @twisted.internet.defer.inlineCallbacks
  16. def icb_error_maker():
  17. """
  18. Raises an exception implemented as an inline inlineCallbacks
  19. """
  20. raise exception_to_raise
  22. def pod_error_maker():
  23. """
  24. Raises an exception implemented as a plain old deferred
  25. """
  26. deferred = twisted.internet.defer.Deferred()
  27. deferred.errback(exception_to_raise)
  28. return deferred
  30. #ERROR_MAKER_TO_USE = icb_error_maker
  31. ERROR_MAKER_TO_USE = pod_error_maker
  33. @twisted.internet.defer.inlineCallbacks
  34. def intermediate_function3():
  36. print 'intermediate_function3 1'
  37. try:
  39. yield ERROR_MAKER_TO_USE()
  41. except BaseException as exception:
  42. print 'intermediate_function3 exception', repr(exception)
  43. raise
  45. print 'intermediate_function3 2'
  48. @twisted.internet.defer.inlineCallbacks
  49. def intermediate_function2():
  51. print 'intermediate_function2 1'
  52. try:
  54. yield intermediate_function3()
  56. except BaseException as exception:
  57. print 'intermediate_function2 exception', repr(exception)
  58. raise
  60. print 'intermediate_function2 2'
  63. @twisted.internet.defer.inlineCallbacks
  64. def intermediate_function1():
  66. print 'intermediate_function1 1'
  67. try:
  69. yield intermediate_function2()
  71. except BaseException as exception:
  72. print 'intermediate_function1 exception', repr(exception)
  73. raise
  76. print 'intermediate_function1 2'
  78. def run():
  79. d = intermediate_function1()
  80. d.addErrback(twisted.python.log.err)
  81. d.addBoth(lambda n: twisted.internet.reactor.stop())
  83. twisted.internet.reactor.callWhenRunning(run)
  84. twisted.internet.reactor.run()
  85.  
Powered by spacepaste. Paste removal.