-def wrap_exceptions(error_message="Unhandled exception"):
- def Inner(func):
- @wraps(func)
- async def wrapper(*args, **kwargs):
- try:
- return await func(*args, **kwargs)
- except Exception as err:
- if isinstance(err, RetryableException):
- raise err
- raise ApplicationError(
- f"{error_message}: {str(err)}", non_retryable=True
- ) from err