merge master

Author: matusdrobuliak66

packages/postgres-database/src/simcore_postgres_database/migration/versions/42ec7816c0b4_computational_collection_runs.py

@@ -119,4 +119,3 @@ def downgrade():
     )
     op.drop_table("comp_runs_collections")
     # ### end Alembic commands ###
-    # ### end Alembic commands ###

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

@@ -502,6 +502,7 @@ async def create(
         use_on_demand_clusters: bool,
         dag_adjacency_list: dict[str, list[str]],
         collection_run_id: CollectionRunID,
+        collection_run_id: CollectionRunID,
     ) -> CompRunsAtDB:
         try:
             async with transaction_context(self.db_engine) as conn:
@@ -519,6 +520,7 @@ async def create(
                         use_on_demand_clusters=use_on_demand_clusters,
                         dag_adjacency_list=dag_adjacency_list,
                         collection_run_id=f"{collection_run_id}",
+                        collection_run_id=f"{collection_run_id}",
                     )
                     .returning(literal_column("*"))
                 )

services/director-v2/tests/unit/with_dbs/comp_scheduler/test_db_repositories_comp_runs.py

@@ -107,6 +107,7 @@ async def test_list(
         use_on_demand_clusters=faker.pybool(),
         dag_adjacency_list=published_project.pipeline.dag_adjacency_list,
         collection_run_id=fake_collection_run_id,
+        collection_run_id=fake_collection_run_id,
     )
     assert await CompRunsRepository(sqlalchemy_async_engine).list_() == [created]
 
@@ -120,6 +121,7 @@ async def test_list(
                 use_on_demand_clusters=faker.pybool(),
                 dag_adjacency_list=published_project.pipeline.dag_adjacency_list,
                 collection_run_id=faker.uuid4(),
+                collection_run_id=faker.uuid4(),
             )
             for n in range(50)
         )