Simple Distributed Promise

simpledistpromise.py

def MyLongRunningFunction(resolve):
  try:
    # we're in a separate task. Do something long running!
    # eventually call resolve(result), with whatever result you made 
  except Exception, ex:
    resolve(ex)

def MyFunctionToRunAfterThat(result):
  try:
    value = result.value 
    # we now have the value passed to resolve. Do something with it.
  except Exception, ex:
    # if resolve() was passed an exception, it'll arrive here when
    # we access result.value
    logging.exception("failure running long running thing")
    
PromiseSpace().when(MyLongRunningFunction).then(MyFunctionToRunAfterThat)