review @pcrespov

Author: matusdrobuliak66

packages/postgres-database/src/simcore_postgres_database/models/comp_runs.py

@@ -99,7 +99,7 @@
         doc="the run uses on demand clusters",
     ),
     sa.Column(
-        "dag_adjacency_list", JSONB, doc="Adjancey list for the pipeline's graph"
+        "dag_adjacency_list", JSONB, doc="Adjacency list for the pipeline's graph"
     ),
     sa.UniqueConstraint("project_uuid", "user_id", "iteration"),
     sa.Index("ix_comp_runs_user_id", "user_id"),

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

@@ -2,6 +2,7 @@
 
 import sqlalchemy as sa
 from pydantic import PositiveInt
+from sqlalchemy.engine.row import Row
 from sqlalchemy.ext.asyncio import AsyncConnection, AsyncEngine
 
 from .models.comp_run_snapshot_tasks import comp_run_snapshot_tasks
@@ -40,9 +41,9 @@ async def update_for_run_id_and_node_id(
     run_id: PositiveInt,
     node_id: str,
     data: dict[str, Any],
-):
+) -> Row:
     async with pass_or_acquire_connection(engine, connection=conn) as _conn:
-        result = await _conn.stream(
+        result = await _conn.execute(
             comp_run_snapshot_tasks.update()
             .values(
                 **data,
@@ -54,7 +55,7 @@ async def update_for_run_id_and_node_id(
             )
             .returning(*COMP_RUN_SNAPSHOT_TASKS_DB_COLS)
         )
-        row = await result.one_or_none()
+        row = result.one_or_none()
         if row is None:
             msg = f"update for run_id={run_id} and node_id={node_id} did not return any row"
             raise ValueError(msg)