fixes

Author: matusdrobuliak66

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

@@ -117,7 +117,7 @@ async def test_list(
                 metadata=run_metadata,
                 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=faker.uuid4(),
             )
             for n in range(50)
         )
@@ -274,7 +274,6 @@ async def test_create(
     run_metadata: RunMetadataDict,
     faker: Faker,
     publish_project: Callable[[], Awaitable[PublishedProject]],
-    fake_collection_run_id: CollectionRunID,
 ):
     with pytest.raises(ProjectNotFoundError):
         await CompRunsRepository(sqlalchemy_async_engine).create(
@@ -284,7 +283,7 @@ async def test_create(
             metadata=run_metadata,
             use_on_demand_clusters=faker.pybool(),
             dag_adjacency_list={},
-            collection_run_id=fake_collection_run_id,
+            collection_run_id=faker.uuid4(),
         )
     published_project = await publish_project()
     with pytest.raises(UserNotFoundError):
@@ -295,7 +294,7 @@ async def test_create(
             metadata=run_metadata,
             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=faker.uuid4(),
         )
 
     created = await CompRunsRepository(sqlalchemy_async_engine).create(
@@ -305,7 +304,7 @@ async def test_create(
         metadata=run_metadata,
         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=faker.uuid4(),
     )
     got = await CompRunsRepository(sqlalchemy_async_engine).get(
         user_id=published_project.user["id"],
@@ -321,7 +320,7 @@ async def test_create(
         metadata=run_metadata,
         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=faker.uuid4(),
     )
     assert created != got
     assert created.iteration == got.iteration + 1

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

@@ -166,7 +166,7 @@ async def _assert_start_pipeline(
     published_project: PublishedProject,
     run_metadata: RunMetadataDict,
     computational_pipeline_rabbit_client_parser: mock.AsyncMock,
-    fake_collection_run_id: CollectionRunID,
+    collection_run_id: CollectionRunID,
 ) -> tuple[CompRunsAtDB, list[CompTaskAtDB]]:
     exp_published_tasks = deepcopy(published_project.tasks)
     assert published_project.project.prj_owner
@@ -176,7 +176,7 @@ async def _assert_start_pipeline(
         project_id=published_project.project.uuid,
         run_metadata=run_metadata,
         use_on_demand_clusters=False,
-        collection_run_id=fake_collection_run_id,
+        collection_run_id=collection_run_id,
     )
 
     # check the database is correctly updated, the run is published

services/web/server/tests/unit/with_dbs/01/test_director_v2_handlers.py

@@ -241,3 +241,49 @@ async def test_list_computations_latest_iteration(
     )
     if user_role != UserRole.ANONYMOUS:
         assert ComputationTaskRestGet.model_validate(data[0])
+
+
+@pytest.mark.parametrize(*standard_role_response(), ids=str)
+async def test_list_computations_latest_iteration(
+    director_v2_service_mock: AioResponsesMock,
+    user_project: ProjectDict,
+    client: TestClient,
+    logged_user: LoggedUser,
+    user_role: UserRole,
+    expected: ExpectedResponse,
+    mock_rpc_list_computations_latest_iteration_tasks: None,
+    mock_rpc_list_computations_latest_iteration_tasks_page: None,
+    mock_rpc_list_computation_iterations: None,
+):
+    assert client.app
+    url = client.app.router["list_computations_latest_iteration"].url_for()
+    resp = await client.get(f"{url}")
+    data, _ = await assert_status(
+        resp, status.HTTP_200_OK if user_role == UserRole.GUEST else expected.ok
+    )
+    if user_role != UserRole.ANONYMOUS:
+        assert ComputationRunRestGet.model_validate(data[0])
+        assert data[0]["rootProjectName"] == user_project["name"]
+
+    url = client.app.router["list_computation_iterations"].url_for(
+        project_id=f"{user_project['uuid']}"
+    )
+    resp = await client.get(f"{url}")
+    data, _ = await assert_status(
+        resp, status.HTTP_200_OK if user_role == UserRole.GUEST else expected.ok
+    )
+    if user_role != UserRole.ANONYMOUS:
+        assert ComputationRunRestGet.model_validate(data[0])
+        assert len(data) == 2
+        assert data[0]["rootProjectName"] == user_project["name"]
+        assert data[1]["rootProjectName"] == user_project["name"]
+
+    url = client.app.router["list_computations_latest_iteration_tasks"].url_for(
+        project_id=f"{user_project['uuid']}"
+    )
+    resp = await client.get(f"{url}")
+    data, _ = await assert_status(
+        resp, status.HTTP_200_OK if user_role == UserRole.GUEST else expected.ok
+    )
+    if user_role != UserRole.ANONYMOUS:
+        assert ComputationTaskRestGet.model_validate(data[0])