task_filter -> owner_metadata

Author: bisgaard-itis

packages/celery-library/src/celery_library/backends/redis.py

@@ -6,6 +6,7 @@
 from models_library.progress_bar import ProgressReport
 from pydantic import ValidationError
 from servicelib.celery.models import (
+    WILDCARD,
     ExecutionMetadata,
     OwnerMetadata,
     Task,
@@ -84,9 +85,9 @@ async def get_task_progress(self, task_id: TaskID) -> ProgressReport | None:
             )
             return None
 
-    async def list_tasks(self, task_filter: OwnerMetadata) -> list[Task]:
-        search_key = _CELERY_TASK_INFO_PREFIX + task_filter.model_dump_task_id(
-            task_uuid="*"
+    async def list_tasks(self, owner_metadata: OwnerMetadata) -> list[Task]:
+        search_key = _CELERY_TASK_INFO_PREFIX + owner_metadata.model_dump_task_id(
+            task_uuid=WILDCARD
         )
 
         keys: list[str] = []

packages/service-library/src/servicelib/celery/models.py

@@ -198,7 +198,7 @@ async def get_task_metadata(self, task_id: TaskID) -> ExecutionMetadata | None:
 
     async def get_task_progress(self, task_id: TaskID) -> ProgressReport | None: ...
 
-    async def list_tasks(self, task_filter: OwnerMetadata) -> list[Task]: ...
+    async def list_tasks(self, owner_metadata: OwnerMetadata) -> list[Task]: ...
 
     async def remove_task(self, task_id: TaskID) -> None: ...