We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e7f3fa2 commit dcd9da3Copy full SHA for dcd9da3
services/storage/src/simcore_service_storage/modules/celery/client.py
@@ -13,7 +13,7 @@
13
_logger = logging.getLogger(__name__)
14
15
_CELERY_TASK_META_PREFIX = "celery-task-meta-"
16
-_PREFIX: Final[str] = "ct"
+_PREFIX: Final[str] = "ct" # short for celery task, not Catania
17
18
19
def _build_parts_prefix(name: str, task_id_parts: TaskIDParts) -> list[str]:
@@ -83,7 +83,7 @@ def _get_completed_task_ids(
83
)
84
redis = self._celery_app.backend.client
85
if hasattr(redis, "keys") and (keys := redis.keys(search_key)):
86
- return [f"{key}".lstrip(_CELERY_TASK_META_PREFIX) for key in keys]
+ return [f"{key}".removeprefix(_CELERY_TASK_META_PREFIX) for key in keys]
87
return []
88
89
@make_async()
0 commit comments