task_owner -> owner

Author: bisgaard-itis

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

@@ -36,9 +36,9 @@ class TaskOwnerMetadata(BaseModel):
         class MyTaskFilter(TaskFilter):
             user_id: int | Wildcard
             product_name: int | Wildcard
-            client_name: str
+            owner: str
 
-        Listing tasks using the filter `MyTaskFilter(user_id=123, product_name=Wildcard(), client_name="my-app")` will return all tasks with
+        Listing tasks using the filter `MyTaskFilter(user_id=123, product_name=Wildcard(), owner="my-app")` will return all tasks with
         user_id 123, any product_name submitted from my-app.
 
     If the metadata schema is known, the class allows deserializing the metadata (recreate_as_model). I.e. one can recover the metadata from the task:
@@ -47,7 +47,7 @@ class MyTaskFilter(TaskFilter):
     """
 
     model_config = ConfigDict(extra="allow", arbitrary_types_allowed=True)
-    task_owner: Annotated[str, StringConstraints(min_length=1, pattern=r"^[a-z_-]+$")]
+    owner: Annotated[str, StringConstraints(min_length=1, pattern=r"^[a-z_-]+$")]
 
     @model_validator(mode="after")
     def _check_valid_filters(self) -> Self:

packages/service-library/tests/test_celery.py

@@ -91,10 +91,10 @@ class MyFilter(TaskOwnerMetadata):
         extra_field: str
 
     with pytest.raises(pydantic.ValidationError):
-        MyFilter(task_owner="", extra_field="value")
+        MyFilter(owner="", extra_field="value")
 
     with pytest.raises(pydantic.ValidationError):
-        MyFilter(task_owner="UPPER_CASE", extra_field="value")
+        MyFilter(owner="UPPER_CASE", extra_field="value")
 
     class MyNextFilter(TaskOwnerMetadata):
         task_owner: Annotated[

services/api-server/src/simcore_service_api_server/models/domain/celery_models.py

@@ -36,6 +36,6 @@
 class ApiWorkerTaskFilter(TaskOwnerMetadata):
     user_id: UserID
     product_name: ProductName
-    task_owner: Annotated[
+    owner: Annotated[
         str, StringConstraints(pattern=rf"^{APP_NAME}$"), Field(frozen=True)
     ] = APP_NAME