sql 2.0

Author: sanderegg

services/web/server/src/simcore_service_webserver/functions/_functions_repository.py

@@ -565,11 +565,11 @@ async def list_function_job_collections(
         ):
             collection = RegisteredFunctionJobCollectionDB.model_validate(row)
             job_ids = [
-                job_row["function_job_uuid"]
+                job_row.function_job_uuid
                 async for job_row in await conn.stream(
                     function_job_collections_to_function_jobs_table.select().where(
                         function_job_collections_to_function_jobs_table.c.function_job_collection_uuid
-                        == row["uuid"]
+                        == row.uuid
                     )
                 )
             ]

services/web/server/tests/unit/with_dbs/04/functions_rpc/conftest.py

@@ -9,6 +9,7 @@
 from uuid import uuid4
 
 import pytest
+import sqlalchemy
 from aiohttp.test_utils import TestClient
 from models_library.api_schemas_webserver.functions import (
     Function,
@@ -188,7 +189,7 @@ async def add_user_function_api_access_rights(
     async with asyncpg_engine.begin() as conn:
         for group_id in (logged_user["primary_gid"], other_logged_user["primary_gid"]):
             await conn.execute(
-                funcapi_api_access_rights_table.delete(  # type: ignore[union-attr]
+                sqlalchemy.delete(funcapi_api_access_rights_table).where(
                     funcapi_api_access_rights_table.c.group_id == group_id
                 )
             )