add first batch of unit tests

Author: matusdrobuliak66

packages/postgres-database/src/simcore_postgres_database/migration/versions/5baec57326b3_computational_collection_runs.py renamed to packages/postgres-database/src/simcore_postgres_database/migration/versions/42ec7816c0b4_computational_collection_runs.py

@@ -1,8 +1,8 @@
 """computational collection runs
 
-Revision ID: 5baec57326b3
+Revision ID: 42ec7816c0b4
 Revises: 4f6fd2586491
-Create Date: 2025-07-01 12:20:10.464764+00:00
+Create Date: 2025-07-01 13:30:02.736058+00:00
 
 """
 
@@ -11,7 +11,7 @@
 from sqlalchemy.dialects import postgresql
 
 # revision identifiers, used by Alembic.
-revision = "5baec57326b3"
+revision = "42ec7816c0b4"
 down_revision = "4f6fd2586491"
 branch_labels = None
 depends_on = None
@@ -21,7 +21,12 @@ def upgrade():
     # ### commands auto generated by Alembic - please adjust! ###
     op.create_table(
         "comp_run_collections",
-        sa.Column("collection_run_id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column(
+            "collection_run_id",
+            postgresql.UUID(as_uuid=True),
+            server_default=sa.text("gen_random_uuid()"),
+            nullable=False,
+        ),
         sa.Column("client_or_system_generated_id", sa.String(), nullable=False),
         sa.Column(
             "client_or_system_generated_display_name", sa.String(), nullable=False
@@ -48,7 +53,7 @@ def upgrade():
         unique=False,
     )
     op.add_column(
-        "comp_runs", sa.Column("collection_run_id", sa.String(), nullable=True)
+        "comp_runs", sa.Column("collection_run_id", sa.String(), nullable=False)
     )
 
     # Data migration: Create collection run records for existing comp_runs

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

@@ -12,6 +12,7 @@
     sa.Column(
         "collection_run_id",
         UUID(as_uuid=True),
+        server_default=sa.text("gen_random_uuid()"),
         nullable=False,
         primary_key=True,
     ),

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_runs.py

@@ -391,8 +391,8 @@ async def list_group_by_collection_run_id(
             comp_runs.c.collection_run_id,
             sa.func.array_agg(comp_runs.c.project_uuid).label("project_ids"),
             sa.func.array_agg(comp_runs.c.result).label("states"),
-            # For simplicity, we use min here:
-            sa.func.min(comp_runs.c.metadata).label("info"),
+            # For simplicity, we use any metadata from the collection (first one in aggregation order):
+            sa.literal_column("(jsonb_agg(comp_runs.metadata))[1]").label("info"),
             sa.func.min(comp_runs.c.created).label("submitted_at"),
             sa.func.min(comp_runs.c.started).label("started_at"),
             sa.func.min(comp_runs.c.run_id).label("min_run_id"),
@@ -416,7 +416,7 @@ async def list_group_by_collection_run_id(
             )
 
         base_select_query_with_group_by = base_select_query.group_by(
-            comp_runs.c.group_by_flag
+            comp_runs.c.collection_run_id
         )
 
         count_query = sa.select(sa.func.count()).select_from(
@@ -441,7 +441,7 @@ async def list_group_by_collection_run_id(
                         collection_run_id=row["collection_run_id"],
                         project_ids=row["project_ids"],
                         state=resolved_state,
-                        info=row["info"],
+                        info={} if row["info"] is None else row["info"],
                         submitted_at=row["submitted_at"],
                         started_at=row["started_at"],
                         ended_at=row["ended_at"],
@@ -475,7 +475,7 @@ async def create(
                         metadata=jsonable_encoder(metadata),
                         use_on_demand_clusters=use_on_demand_clusters,
                         dag_adjacency_list=dag_adjacency_list,
-                        collection_run_id=collection_run_id,
+                        collection_run_id=f"{collection_run_id}",
                     )
                     .returning(literal_column("*"))
                 )