fixes update

Author: pcrespov

services/web/server/src/simcore_service_webserver/projects/_crud_api_read.py

@@ -28,11 +28,6 @@
 from .models import ProjectDict, ProjectTypeAPI
 
 
-async def _sequential_execution(*coros):
-    for coro in coros:
-        await coro  # Ensures each coroutine runs in sequence
-
-
 async def _batch_update_list_of_project_dict(
     app: web.Application, list_of_project_dict: list[ProjectDict]
 ) -> list[ProjectDict]:
@@ -50,6 +45,27 @@ async def _batch_update_list_of_project_dict(
     return list_of_project_dict
 
 
+async def _update_and_get_project_dict(
+    request: web.Request,
+    *,
+    user_id: UserID,
+    project: ProjectDict,
+    is_template: bool,
+) -> ProjectDict:
+    # state
+    await projects_service.add_project_states_for_user(
+        user_id=user_id,
+        project=project,
+        is_template=is_template,
+        app=request.app,
+    )
+
+    # permalink
+    await update_or_pop_permalink_in_project(request, project)
+
+    return project
+
+
 async def list_projects(  # pylint: disable=too-many-arguments
     request: web.Request,
     user_id: UserID,
@@ -135,16 +151,11 @@ async def list_projects(  # pylint: disable=too-many-arguments
 
     projects: list[ProjectDict] = await logged_gather(
         *(
-            _sequential_execution(
-                # state
-                projects_service.add_project_states_for_user(
-                    user_id=user_id,
-                    project=prj,
-                    is_template=prj_type == ProjectTypeDB.TEMPLATE,
-                    app=request.app,
-                ),
-                # permalink
-                update_or_pop_permalink_in_project(request, project=prj),
+            _update_and_get_project_dict(
+                request,
+                user_id=user_id,
+                project=prj,
+                is_template=prj_type == ProjectTypeDB.TEMPLATE,
             )
             for prj, prj_type in zip(db_projects, db_project_types, strict=False)
         ),

services/web/server/src/simcore_service_webserver/projects/_crud_handlers.py

@@ -62,7 +62,10 @@
     ProjectsListQueryParams,
     ProjectsSearchQueryParams,
 )
-from ._permalink_api import update_or_pop_permalink_in_project
+from ._permalink_api import (
+    aggregate_permalink_in_project,
+    update_or_pop_permalink_in_project,
+)
 from .exceptions import (
     ProjectDeleteError,
     ProjectInvalidRightsError,
@@ -270,7 +273,7 @@ async def list_projects_full_search(request: web.Request):
         # that depend on the **request**.
         *(
             # permalink
-            update_or_pop_permalink_in_project(request, prj)
+            aggregate_permalink_in_project(request, project=prj)
             for prj in projects
         ),
         reraise=True,

services/web/server/src/simcore_service_webserver/projects/_permalink_api.py

@@ -77,4 +77,14 @@ async def update_or_pop_permalink_in_project(
     return None
 
 
+async def aggregate_permalink_in_project(
+    request: web.Request, project: ProjectDict
+) -> ProjectDict:
+    """
+    Adapter to use in parallel aggregation of fields in a project dataset
+    """
+    await update_or_pop_permalink_in_project(request, project)
+    return project
+
+
 __all__: tuple[str, ...] = ("ProjectPermalink",)