fix tests

Author: giancarloromeo

services/storage/src/simcore_service_storage/modules/celery/backends/_redis.py

@@ -2,7 +2,8 @@
 from datetime import timedelta
 from typing import Final
 
-from celery.result import AsyncResult  # type: ignore[import-untyped]
+from celery.result import AsyncResult
+from common_library.async_tools import make_async  # type: ignore[import-untyped]
 from models_library.progress_bar import ProgressReport
 from servicelib.redis._client import RedisClientSDK
 
@@ -51,7 +52,7 @@ async def create_task(
         )
 
     async def exists_task(self, task_id: TaskID) -> bool:
-        n = await self._redis_client_sdk.redis.exists(_build_key(task_id))  # type: ignore
+        n = await self._redis_client_sdk.redis.exists(_build_key(task_id))
         assert isinstance(n, int)  # nosec
         return n > 0
 
@@ -96,10 +97,15 @@ async def list_tasks(self, task_context: TaskContext) -> list[Task]:
             if metadata is not None
         ]
 
-    async def remove_task(self, task_id: TaskID) -> None:
-        await self._redis_client_sdk.redis.delete(_build_key(task_id))  # type: ignore
+    @make_async()
+    @staticmethod
+    def _forget_task(task_id: TaskID) -> None:
         AsyncResult(task_id).forget()
 
+    async def remove_task(self, task_id: TaskID) -> None:
+        await self._redis_client_sdk.redis.delete(_build_key(task_id))
+        await self._forget_task(task_id)
+
     async def set_task_progress(self, task_id: TaskID, report: ProgressReport) -> None:
         await self._redis_client_sdk.redis.hset(
             name=_build_key(task_id),

services/web/server/tests/unit/with_dbs/01/storage/test_storage.py

@@ -433,7 +433,12 @@ def side_effect(*args, **kwargs):
     "backend_result_or_exception, expected_status",
     [
         (
-            (AsyncJobGet(job_id=AsyncJobId(f"{_faker.uuid4()}")), None),
+            (
+                AsyncJobGet(
+                    job_id=AsyncJobId(f"{_faker.uuid4()}"), job_name="export_data"
+                ),
+                None,
+            ),
             status.HTTP_202_ACCEPTED,
         ),
         (
@@ -594,6 +599,7 @@ async def test_get_async_job_result(
             [
                 AsyncJobGet(
                     job_id=AsyncJobId(_faker.uuid4()),
+                    job_name="task_name",
                 )
             ],
             status.HTTP_200_OK,
@@ -672,7 +678,13 @@ async def test_get_async_job_links(
     create_storage_rpc_client_mock(
         "simcore_service_webserver.storage._rest",
         start_export_data.__name__,
-        (AsyncJobGet(job_id=AsyncJobId(f"{_faker.uuid4()}")), None),
+        (
+            AsyncJobGet(
+                job_id=AsyncJobId(f"{_faker.uuid4()}"),
+                job_name="export_data",
+            ),
+            None,
+        ),
     )
 
     _body = DataExportPost(