Synnefo » snf-ganeti

  while True:

    retry_args = []

    try:

      return fn(*args)

    except RetryAgain, err:

      retry_args = err.args

    remaining_time = end_time - _time_fn()

    if remaining_time < 0.0:

      raise RetryTimeout(*retry_args)

    assert remaining_time >= 0.0

  rdict = {}

  def helper(*innerargs):

    result = rdict["result"] = fn(*innerargs)

    if not ((callable(expected) and expected(result)) or result == expected):

      raise RetryAgain()