retrier: raise initial exception instead of OperationalException
This commit is contained in:
parent
5baab91bb5
commit
20af4bae7c
@ -41,7 +41,8 @@ def retrier(f):
|
|||||||
logger.warning('retrying %s() still for %s times', f.__name__, count)
|
logger.warning('retrying %s() still for %s times', f.__name__, count)
|
||||||
return wrapper(*args, **kwargs)
|
return wrapper(*args, **kwargs)
|
||||||
else:
|
else:
|
||||||
raise OperationalException('Giving up retrying: %s()', f.__name__)
|
logger.warning('Giving up retrying: %s()', f.__name__)
|
||||||
|
raise ex
|
||||||
return wrapper
|
return wrapper
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user