rename repo methods

Author: giancarloromeo

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

@@ -1,7 +1,6 @@
 import logging
 
 import sqlalchemy as sa
-
 from aiohttp import web
 from models_library.projects import ProjectID
 from models_library.projects_nodes import Node, PartialNode
@@ -10,8 +9,8 @@
 from simcore_postgres_database.webserver_models import projects_nodes
 from sqlalchemy.ext.asyncio import AsyncConnection
 
-from .exceptions import NodeNotFoundError
 from ..db.plugin import get_asyncpg_engine
+from .exceptions import NodeNotFoundError
 
 _logger = logging.getLogger(__name__)
 
@@ -36,17 +35,15 @@
 ]
 
 
-async def get(
+async def get_node(
     app: web.Application,
     connection: AsyncConnection | None = None,
     *,
     project_id: ProjectID,
     node_id: NodeID,
 ) -> Node:
     async with transaction_context(get_asyncpg_engine(app), connection) as conn:
-        get_stmt = sa.select(
-            *_SELECTION_PROJECTS_NODES_DB_ARGS
-        ).where(
+        get_stmt = sa.select(*_SELECTION_PROJECTS_NODES_DB_ARGS).where(
             (projects_nodes.c.project_uuid == f"{project_id}")
             & (projects_nodes.c.node_id == f"{node_id}")
         )
@@ -57,14 +54,13 @@ async def get(
         row = await result.first()
         if row is None:
             raise NodeNotFoundError(
-                project_uuid=f"{project_id}",
-                node_uuid=f"{node_id}"
+                project_uuid=f"{project_id}", node_uuid=f"{node_id}"
             )
         assert row  # nosec
         return Node.model_validate(row, from_attributes=True)
 
 
-async def update(
+async def update_node(
     app: web.Application,
     connection: AsyncConnection | None = None,
     *,

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

@@ -985,7 +985,7 @@ async def update_project_node_state(
         new_node_data={"state": {"currentStatus": new_state}},
     )
 
-    await _projects_nodes_repository.update(
+    await _projects_nodes_repository.update_node(
         app,
         project_id=project_id,
         node_id=node_id,
@@ -1057,7 +1057,7 @@ async def patch_project_node(
         new_node_data=_node_patch_exclude_unset,
     )
 
-    await _projects_nodes_repository.update(
+    await _projects_nodes_repository.update_node(
         app,
         project_id=project_id,
         node_id=node_id,
@@ -1125,7 +1125,7 @@ async def update_project_node_outputs(
         new_node_data={"outputs": new_outputs, "runHash": new_run_hash},
     )
 
-    await _projects_nodes_repository.update(
+    await _projects_nodes_repository.update_node(
         app,
         project_id=project_id,
         node_id=node_id,