@@ -473,56 +473,8 @@ async def _fake_download_to_file_or_raise(session, url, dest_path):
473473 )
474474 ],
475475)
476+ @pytest .mark .parametrize ("num_concurrent_calls" , [1 , 20 ])
476477async def test_create_and_delete_folders_from_project (
477- set_log_levels_for_noisy_libraries : None ,
478- initialized_app : FastAPI ,
479- storage_rabbitmq_rpc_client : RabbitMQRPCClient ,
480- client : httpx .AsyncClient ,
481- user_id : UserID ,
482- product_name : str ,
483- create_project : Callable [..., Awaitable [dict [str , Any ]]],
484- with_random_project_with_files : tuple [
485- dict [str , Any ],
486- dict [NodeID , dict [SimcoreS3FileID , dict [str , Path | str ]]],
487- ],
488- mock_datcore_download ,
489- ):
490- project_in_db , _ = with_random_project_with_files
491- await _create_and_delete_folders_from_project (
492- storage_rabbitmq_rpc_client ,
493- client ,
494- user_id ,
495- product_name ,
496- project_in_db ,
497- initialized_app ,
498- create_project ,
499- check_list_files = True ,
500- )
501-
502-
503- @pytest .mark .flaky (max_runs = 3 )
504- @pytest .mark .parametrize (
505- "location_id" ,
506- [SimcoreS3DataManager .get_location_id ()],
507- ids = [SimcoreS3DataManager .get_location_name ()],
508- indirect = True ,
509- )
510- @pytest .mark .parametrize (
511- "project_params" ,
512- [
513- ProjectWithFilesParams (
514- num_nodes = 3 ,
515- allowed_file_sizes = (
516- TypeAdapter (ByteSize ).validate_python ("7Mib" ),
517- TypeAdapter (ByteSize ).validate_python ("110Mib" ),
518- TypeAdapter (ByteSize ).validate_python ("1Mib" ),
519- ),
520- workspace_files_count = 0 ,
521- )
522- ],
523- )
524- @pytest .mark .parametrize ("num_concurrent_calls" , [20 ])
525- async def test_create_and_delete_folders_from_project_burst (
526478 set_log_levels_for_noisy_libraries : None ,
527479 initialized_app : FastAPI ,
528480 storage_rabbitmq_rpc_client : RabbitMQRPCClient ,
0 commit comments