fix: job_filter

Author: giancarloromeo

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/storage/simcore_s3.py

@@ -50,11 +50,9 @@ async def start_export_data(
 async def start_search(
     rabbitmq_rpc_client: RabbitMQRPCClient,
     *,
-    user_id: UserID,
-    product_name: ProductName,
+    job_filter: AsyncJobFilter,
     name_pattern: str,
 ) -> tuple[AsyncJobGet, AsyncJobFilter]:
-    job_filter = get_async_job_filter(user_id=user_id, product_name=product_name)
     async_job_rpc_get = await submit(
         rabbitmq_rpc_client,
         rpc_namespace=STORAGE_RPC_NAMESPACE,

services/web/server/src/simcore_service_webserver/storage/_rest.py

@@ -546,9 +546,11 @@ def allow_only_simcore(cls, v: int) -> int:
         model_schema_cls=SearchBodyParams, request=request
     )
     async_job_rpc_get, _ = await start_search(
-        rabbitmq_rpc_client=rabbitmq_rpc_client,
-        user_id=_req_ctx.user_id,
-        product_name=_req_ctx.product_name,
+        rabbitmq_rpc_client,
+        job_filter=get_job_filter(
+            user_id=_req_ctx.user_id,
+            product_name=_req_ctx.product_name,
+        ),
         name_pattern=search_body.name_pattern,
     )
     _job_id = f"{async_job_rpc_get.job_id}"