reverted

Author: sanderegg

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

@@ -78,16 +78,15 @@ def abort_task(task_context: TaskContext, task_uuid: TaskUUID) -> None:
         _logger.info("Aborting task %s", task_id)
         AbortableAsyncResult(task_id).abort()
 
-    @staticmethod
     @make_async()
-    def get_task_result(task_context: TaskContext, task_uuid: TaskUUID) -> Any:
+    def get_task_result(self, task_context: TaskContext, task_uuid: TaskUUID) -> Any:
         task_id = _build_task_id(task_context, task_uuid)
         with log_context(
             _logger,
             logging.DEBUG,
             msg=f"Getting  task {task_id=} result",
         ):
-            return AbortableAsyncResult(task_id).result
+            return self._celery_app.AsyncResult(task_id).result
 
     def _get_progress_report(
         self, task_context: TaskContext, task_uuid: TaskUUID