Skip to content

Commit 317ee66

Browse files
update keys
1 parent c75ccae commit 317ee66

File tree

1 file changed

+3
-7
lines changed
  • services/storage/src/simcore_service_storage/modules/celery

1 file changed

+3
-7
lines changed

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

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
"revoked",
2222
)
2323
_CELERY_TASK_META_PREFIX: Final[str] = "celery-task-meta-"
24-
_CELERY_TASK_ID_PREFIX: Final[str] = "celery"
2524
_CELERY_STATES_MAPPING: Final[dict[str, TaskState]] = {
2625
"PENDING": TaskState.PENDING,
2726
"STARTED": TaskState.PENDING,
@@ -33,18 +32,15 @@
3332

3433

3534
def _build_context_prefix(task_context: TaskContext) -> list[str]:
36-
return [
37-
_CELERY_TASK_ID_PREFIX,
38-
*[f"{task_context[key]}" for key in sorted(task_context)],
39-
]
35+
return [f"{task_context[key]}" for key in sorted(task_context)]
4036

4137

4238
def _build_task_id_prefix(task_context: TaskContext) -> str:
43-
return "::".join(_build_context_prefix(task_context))
39+
return ":".join(_build_context_prefix(task_context))
4440

4541

4642
def _build_task_id(task_context: TaskContext, task_uuid: TaskUUID) -> TaskID:
47-
return "::".join([_build_task_id_prefix(task_context), f"{task_uuid}"])
43+
return ":".join([_build_task_id_prefix(task_context), f"{task_uuid}"])
4844

4945

5046
class CeleryTaskQueueClient:

0 commit comments

Comments
 (0)