@@ -1247,7 +1247,7 @@ async def test_list_group_by_collection_run_id_state_priority_precedence(
12471247 assert collection_item .state == RunningState .FAILED
12481248
12491249
1250- async def test_get_with_user_id_none_across_multiple_users (
1250+ async def test_get_latest_run_by_project (
12511251 sqlalchemy_async_engine : AsyncEngine ,
12521252 run_metadata : RunMetadataDict ,
12531253 faker : Faker ,
@@ -1269,6 +1269,7 @@ async def test_get_with_user_id_none_across_multiple_users(
12691269 metadata = run_metadata ,
12701270 use_on_demand_clusters = faker .pybool (),
12711271 dag_adjacency_list = published_project .pipeline .dag_adjacency_list ,
1272+ collection_run_id = CollectionRunID (faker .uuid4 ()),
12721273 )
12731274
12741275 # Create comp runs for the second user (this should increment iteration)
@@ -1279,6 +1280,7 @@ async def test_get_with_user_id_none_across_multiple_users(
12791280 metadata = run_metadata ,
12801281 use_on_demand_clusters = faker .pybool (),
12811282 dag_adjacency_list = published_project .pipeline .dag_adjacency_list ,
1283+ collection_run_id = CollectionRunID (faker .uuid4 ()),
12821284 )
12831285
12841286 # Create another run for the first user (should be iteration 3)
@@ -1289,6 +1291,7 @@ async def test_get_with_user_id_none_across_multiple_users(
12891291 metadata = run_metadata ,
12901292 use_on_demand_clusters = faker .pybool (),
12911293 dag_adjacency_list = published_project .pipeline .dag_adjacency_list ,
1294+ collection_run_id = CollectionRunID (faker .uuid4 ()),
12921295 )
12931296
12941297 # Verify iterations are correct
0 commit comments