while True:
retry_args = []
try:
- # pylint: disable-msg=W0142
+ # pylint: disable=W0142
return fn(*args)
except RetryAgain, err:
retry_args = err.args
remaining_time = end_time - _time_fn()
- if remaining_time < 0.0:
- # pylint: disable-msg=W0142
+ if remaining_time <= 0.0:
+ # pylint: disable=W0142
raise RetryTimeout(*retry_args)
- assert remaining_time >= 0.0
+ assert remaining_time > 0.0
if calc_delay is None:
wait_fn(remaining_time)
"""
rdict = {}
+
def helper(*innerargs):
- # pylint: disable-msg=W0142
+ # pylint: disable=W0142
result = rdict["result"] = fn(*innerargs)
if not ((callable(expected) and expected(result)) or result == expected):
raise RetryAgain()