fix test

Author: giancarloromeo

packages/postgres-database/src/simcore_postgres_database/utils_projects_nodes.py

@@ -40,6 +40,9 @@ class ProjectNodesDuplicateNodeError(BaseProjectNodesError):
 class ProjectNodeCreate(BaseModel):
     node_id: uuid.UUID
     required_resources: dict[str, Any] = Field(default_factory=dict)
+    key: str
+    version: str
+    label: str
 
     @classmethod
     def get_field_names(cls, *, exclude: set[str]) -> set[str]:
@@ -65,7 +68,7 @@ async def add(
         *,
         nodes: list[ProjectNodeCreate],
     ) -> list[ProjectNode]:
-        """creates a new entry in *projects_nodes* and *projects_to_projects_nodes* tables
+        """Creates a new entry in *projects_nodes* table
 
         NOTE: Do not use this in an asyncio.gather call as this will fail!
 

packages/pytest-simcore/src/pytest_simcore/helpers/webserver_projects.py

@@ -81,8 +81,11 @@ async def create_project(
                 required_resources=ServiceResourcesDictHelpers.model_config[
                     "json_schema_extra"
                 ]["examples"][0],
+                key=node_info.get("key"),
+                version=node_info.get("version"),
+                label=node_info.get("label"),
             )
-            for node_id in project_data.get("workbench", {})
+            for node_id, node_info in project_data.get("workbench", {}).items()
         },
     )
 

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

@@ -216,19 +216,27 @@ def _reraise_if_not_unique_uuid_error(err: UniqueViolation):
                             if project_nodes is None:
                                 project_nodes = {
                                     NodeID(node_id): ProjectNodeCreate(
-                                        node_id=NodeID(node_id), required_resources={}
+                                        node_id=NodeID(node_id),
+                                        required_resources={},
+                                        key=node_info.get("key"),
+                                        version=node_info.get("version"),
+                                        label=node_info.get("label"),
                                     )
-                                    for node_id in selected_values["workbench"]
+                                    for node_id, node_info in selected_values["workbench"].items()
                                 }
 
                             nodes = [
                                 project_nodes.get(
                                     NodeID(node_id),
                                     ProjectNodeCreate(
-                                        node_id=NodeID(node_id), required_resources={}
+                                        node_id=NodeID(node_id),
+                                        required_resources={},
+                                        key=node_info.get("key"),
+                                        version=node_info.get("version"),
+                                        label=node_info.get("label"),
                                     ),
                                 )
-                                for node_id in selected_values["workbench"]
+                                for node_id, node_info in selected_values["workbench"].items()
                             ]
                             await project_nodes_repo.add(conn, nodes=nodes)
         return selected_values