fix: result

Author: giancarloromeo

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

@@ -61,6 +61,7 @@ async def start_search(
     rabbitmq_rpc_client: RabbitMQRPCClient,
     *,
     owner_metadata: OwnerMetadata,
+    user_id: UserID,
     limit: int,
     name_pattern: str,
     modified_at: (
@@ -73,6 +74,7 @@ async def start_search(
         rpc_namespace=STORAGE_RPC_NAMESPACE,
         method_name=TypeAdapter(RPCMethodName).validate_python("start_search"),
         owner_metadata=owner_metadata,
+        user_id=user_id,
         limit=limit,
         name_pattern=name_pattern,
         modified_at=modified_at,

services/storage/src/simcore_service_storage/api/rpc/_simcore_s3.py

@@ -49,9 +49,9 @@ async def copy_folders_from_project(
 async def start_export_data(
     task_manager: TaskManager,
     owner_metadata: OwnerMetadata,
+    user_id: UserID,
     paths_to_export: list[PathToExport],
     export_as: Literal["path", "download_link"],
-    user_id: UserID,
 ) -> AsyncJobGet:
     if export_as == "path":
         task_name = export_data.__name__
@@ -75,7 +75,8 @@ async def start_export_data(
 @router.expose()
 async def start_search(
     task_manager: TaskManager,
-    job_filter: AsyncJobFilter,
+    owner_metadata: OwnerMetadata,
+    user_id: UserID,
     limit: int,
     name_pattern: str,
     modified_at: (
@@ -84,14 +85,13 @@ async def start_search(
     project_id: str | None = None,
 ) -> AsyncJobGet:
     task_name = search.__name__
-    task_filter = TaskFilter.model_validate(job_filter.model_dump())
     task_uuid = await task_manager.submit_task(
-        task_metadata=TaskMetadata(
+        execution_metadata=ExecutionMetadata(
             name=task_name,
             streamed_result=True,
         ),
-        task_filter=task_filter,
-        user_id=job_filter.user_id,
+        owner_metadata=owner_metadata,
+        user_id=user_id,
         project_id=project_id,
         limit=limit,
         name_pattern=name_pattern,

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

@@ -564,6 +564,7 @@ class _PathParams(BaseModel):
                 product_name=_req_ctx.product_name,
             ).model_dump()
         ),
+        user_id=_req_ctx.user_id,
         limit=search_body.limit,
         name_pattern=search_body.filters.name_pattern,
         modified_at=(

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

@@ -186,7 +186,7 @@ async def get_async_job_result(request: web.Request) -> web.Response:
     )
 
     return create_data_response(
-        TaskResult(result=task_result, error=None),
+        TaskResult(result=task_result.result, error=None),
         status=status.HTTP_200_OK,
     )