fix key prefix

giancarloromeo · giancarloromeo · commit 8d96c9a99ddc · 2025-04-07T12:18:40.000+02:00
diff --git a/services/storage/src/simcore_service_storage/modules/celery/backends/_redis.py b/services/storage/src/simcore_service_storage/modules/celery/backends/_redis.py
@@ -36,6 +36,6 @@ async def task_exists(self, task_id: TaskID) -> bool:
 
     async def set_task(self, task_id: TaskID, task_data: TaskData) -> None:
         await self._redis_client_sdk.redis.set(
-            task_id,
+            _CELERY_TASK_META_PREFIX + task_id,
             task_data.model_dump_json(),
         )

Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,6 @@ async def task_exists(self, task_id: TaskID) -> bool:`
`36`	`36`
`37`	`37`	`async def set_task(self, task_id: TaskID, task_data: TaskData) -> None:`
`38`	`38`	`await self._redis_client_sdk.redis.set(`
`39`		`- task_id,`
	`39`	`+ _CELERY_TASK_META_PREFIX + task_id,`
`40`	`40`	`task_data.model_dump_json(),`
`41`	`41`	`)`