fix tests

Author: giancarloromeo

services/web/server/tests/unit/with_dbs/02/test_projects_nodes_handler.py

@@ -48,7 +48,6 @@
 from servicelib.aiohttp import status
 from servicelib.common_headers import UNDEFINED_DEFAULT_SIMCORE_USER_AGENT_VALUE
 from settings_library.redis import RedisSettings
-from simcore_postgres_database.models.projects import projects as projects_db_model
 from simcore_postgres_database.models.projects_nodes import projects_nodes
 from simcore_service_webserver.db.models import UserRole
 from simcore_service_webserver.projects._controller.nodes_rest import (
@@ -462,19 +461,20 @@ def inc_running_services(self, *args, **kwargs):  # noqa: ARG002
     # check that we do have NUM_DY_SERVICES nodes in the project
     with postgres_db.connect() as conn:
         result = conn.execute(
-            sa.select(projects_db_model.c.workbench).where(
-                projects_db_model.c.uuid == user_project["uuid"]
+            sa.select(projects_nodes.c.node_id).where(
+                projects_nodes.c.project_uuid == user_project["uuid"]
             )
         )
         assert result
-        workbench = result.one()[projects_db_model.c.workbench]
-    assert len(workbench) == NUM_DY_SERVICES + num_services_in_project
+        node_ids = result.scalars().all()
+    assert len(node_ids) == NUM_DY_SERVICES + num_services_in_project
     print(f"--> {NUM_DY_SERVICES} nodes were created concurrently")
     #
     # delete now
     #
     delete_node_tasks = []
-    for node_id in workbench:
+
+    for node_id in node_ids:
         delete_url = client.app.router["delete_node"].url_for(
             project_id=user_project["uuid"], node_id=node_id
         )
@@ -595,13 +595,13 @@ async def inc_running_services(self, *args, **kwargs):  # noqa: ARG002
     # check that we do have NUM_DY_SERVICES nodes in the project
     with postgres_db.connect() as conn:
         result = conn.execute(
-            sa.select(projects_db_model.c.workbench).where(
-                projects_db_model.c.uuid == project["uuid"]
+            sa.select(projects_nodes.c.node_id).where(
+                projects_nodes.c.project_uuid == project["uuid"]
             )
         )
         assert result
-        workbench = result.one()[projects_db_model.c.workbench]
-    assert len(workbench) == NUM_DY_SERVICES
+        node_ids = result.scalars().all()
+    assert len(node_ids) == NUM_DY_SERVICES
 
 
 @pytest.mark.parametrize(*standard_user_role())