fixed broken test for autoretry

Author: Andrei Neagu

services/storage/src/simcore_service_storage/api/rpc/_async_jobs.py

@@ -95,18 +95,19 @@ async def result(
     if _status.task_state == TaskState.ABORTED:
         raise JobAbortedError(job_id=job_id)
     if _status.task_state == TaskState.ERROR:
-        # NOTE: recover original error from wrapped error
-        exception = None
-        exc_type = None
-        exc_msg = f"{_result}"  # try to deseialise something
+        # fallback exception to report
+        exc_type = type(_result).__name__
+        exc_msg = f"{_result}"
 
+        # try to recover the original error
+        exception = None
         with log_catch(_logger, reraise=False):
             exception = decode_celery_transferrable_error(_result)
             exc_type = type(exception).__name__
             exc_msg = f"{exception}"
 
         if exception is None:
-            _logger.warning("Was not expecting %s", _result)
+            _logger.warning("Was not expecting '%s': '%s'", exc_type, exc_msg)
 
         # NOTE: cannot transfer original exception since this will not be able to be serialized
         # outside of storage

services/storage/src/simcore_service_storage/modules/celery/_task.py

@@ -71,7 +71,8 @@ def wrapper(task: AbortableTask, *args: P.args, **kwargs: P.kwargs) -> R:
             except Exception as exc:
                 if isinstance(exc, dont_autoretry_for):
                     _logger.debug("Not retrying for exception %s", type(exc).__name__)
-                    raise  # propagate without retry
+                    # propagate without retry
+                    raise encore_celery_transferrable_error(exc) from exc
 
                 exc_type = type(exc).__name__
                 exc_message = f"{exc}"