client_name -> TaskOwner

Author: bisgaard-itis

packages/celery-library/tests/unit/test_async_jobs.py

@@ -160,7 +160,7 @@ async def _start_task_via_rpc(
     **kwargs: Any,
 ) -> tuple[AsyncJobGet, AsyncJobFilter]:
     job_filter = AsyncJobFilter(
-        user_id=user_id, product_name=product_name, client_name="pytest_client"
+        user_id=user_id, product_name=product_name, task_owner="pytest_client"
     )
     async_job_get = await async_jobs.submit(
         rabbitmq_rpc_client=client,

packages/models-library/src/models_library/api_schemas_rpc_async_jobs/async_jobs.py

@@ -67,7 +67,7 @@ class AsyncJobFilter(AsyncJobFilterBase):
 
     product_name: ProductName
     user_id: UserID
-    client_name: Annotated[  # this is the name of the app which *submits* the async job. It is mainly used for filtering purposes
+    task_owner: Annotated[  # this is the name of the app which *submits* the async job. It is mainly used for filtering purposes
         str,
         StringConstraints(min_length=1, pattern=r"^[^\s]+$"),
     ]

packages/service-library/tests/rabbitmq/test_rabbitmq_rpc_interfaces_async_jobs.py

@@ -42,7 +42,7 @@ def job_filter(faker: Faker) -> AsyncJobFilter:
     return AsyncJobFilter(
         user_id=faker.pyint(min_value=1),
         product_name=faker.word(),
-        client_name=_ASYNC_JOB_CLIENT_NAME,
+        task_owner=_ASYNC_JOB_CLIENT_NAME,
     )
 
 

services/api-server/src/simcore_service_api_server/services_rpc/storage.py

@@ -19,7 +19,7 @@
 
 def get_job_filter(user_id: UserID, product_name: ProductName) -> AsyncJobFilter:
     return AsyncJobFilter(
-        user_id=user_id, product_name=product_name, client_name=APP_NAME
+        user_id=user_id, product_name=product_name, task_owner=APP_NAME
     )
 
 

services/storage/tests/unit/test_rpc_handlers_paths.py

@@ -74,7 +74,7 @@ async def _assert_compute_path_size(
         location_id=location_id,
         path=path,
         job_filter=AsyncJobFilter(
-            user_id=user_id, product_name=product_name, client_name="PYTEST_CLIENT_NAME"
+            user_id=user_id, product_name=product_name, task_owner="PYTEST_CLIENT_NAME"
         ),
     )
     async for job_composed_result in wait_and_get_result(
@@ -83,7 +83,7 @@ async def _assert_compute_path_size(
         method_name=RPCMethodName(compute_path_size.__name__),
         job_id=async_job.job_id,
         job_filter=AsyncJobFilter(
-            user_id=user_id, product_name=product_name, client_name="PYTEST_CLIENT_NAME"
+            user_id=user_id, product_name=product_name, task_owner="PYTEST_CLIENT_NAME"
         ),
         client_timeout=datetime.timedelta(seconds=120),
     ):
@@ -111,7 +111,7 @@ async def _assert_delete_paths(
         location_id=location_id,
         paths=paths,
         job_filter=AsyncJobFilter(
-            user_id=user_id, product_name=product_name, client_name="PYTEST_CLIENT_NAME"
+            user_id=user_id, product_name=product_name, task_owner="PYTEST_CLIENT_NAME"
         ),
     )
     async for job_composed_result in wait_and_get_result(
@@ -120,7 +120,7 @@ async def _assert_delete_paths(
         method_name=RPCMethodName(compute_path_size.__name__),
         job_id=async_job.job_id,
         job_filter=AsyncJobFilter(
-            user_id=user_id, product_name=product_name, client_name="PYTEST_CLIENT_NAME"
+            user_id=user_id, product_name=product_name, task_owner="PYTEST_CLIENT_NAME"
         ),
         client_timeout=datetime.timedelta(seconds=120),
     ):

services/storage/tests/unit/test_rpc_handlers_simcore_s3.py

@@ -93,7 +93,7 @@ async def _request_copy_folders(
             job_filter=AsyncJobFilter(
                 user_id=user_id,
                 product_name=product_name,
-                client_name="PYTEST_CLIENT_NAME",
+                task_owner="PYTEST_CLIENT_NAME",
             ),
         )
 
@@ -537,7 +537,7 @@ async def _request_start_export_data(
             job_filter=AsyncJobFilter(
                 user_id=user_id,
                 product_name=product_name,
-                client_name="PYTEST_CLIENT_NAME",
+                task_owner="PYTEST_CLIENT_NAME",
             ),
         )
 

services/web/server/src/simcore_service_webserver/utils.py

@@ -129,5 +129,5 @@ def compose_support_error_msg(
 
 def get_job_filter(*, user_id: UserID, product_name: ProductName) -> AsyncJobFilter:
     return AsyncJobFilter(
-        user_id=user_id, product_name=product_name, client_name=APP_NAME
+        user_id=user_id, product_name=product_name, task_owner=APP_NAME
     )