Skip to content

Commit 39fc47e

Browse files
remove prefix when forgetting
1 parent 3b3da36 commit 39fc47e

File tree

1 file changed

+1
-2
lines changed
  • services/storage/src/simcore_service_storage/modules/celery/backends

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77

88
from ..models import TaskContext, TaskID, TaskMetadata, TaskUUID, build_task_id_prefix
99

10-
_CELERY_TASK_META_PREFIX: Final[str] = "celery-task-meta-"
1110
_CELERY_TASK_METADATA_PREFIX: Final[str] = "celery-task-metadata-"
1211
_CELERY_TASK_ID_KEY_ENCODING = "utf-8"
1312
_CELERY_TASK_ID_KEY_SEPARATOR: Final[str] = ":"
@@ -54,7 +53,7 @@ async def get_uuids(self, task_context: TaskContext) -> set[TaskUUID]:
5453

5554
async def remove(self, task_id: TaskID) -> None:
5655
await self._redis_client_sdk.redis.delete(_build_key(task_id))
57-
AsyncResult(_CELERY_TASK_META_PREFIX + task_id).forget()
56+
AsyncResult(task_id).forget()
5857

5958
async def set(
6059
self, task_id: TaskID, task_metadata: TaskMetadata, expiry: timedelta

0 commit comments

Comments
 (0)