3131from fastapi import FastAPI
3232from models_library .api_schemas_directorv2 .services import NodeRequirements
3333from models_library .api_schemas_storage import FileUploadLinks , FileUploadSchema
34- from models_library .clusters import ClusterID
3534from models_library .docker import to_simcore_runtime_docker_label_key
3635from models_library .projects import ProjectID
3736from models_library .projects_nodes_io import NodeID , SimCoreFileLink , SimcoreS3FileID
@@ -100,7 +99,9 @@ async def mocked_node_ports_filemanager_fcts(
10099 ],
101100 chunk_size = TypeAdapter (ByteSize ).validate_python ("5GiB" ),
102101 links = FileUploadLinks (
103- abort_upload = TypeAdapter (AnyUrl ).validate_python ("https://www.fakeabort.com" ),
102+ abort_upload = TypeAdapter (AnyUrl ).validate_python (
103+ "https://www.fakeabort.com"
104+ ),
104105 complete_upload = TypeAdapter (AnyUrl ).validate_python (
105106 "https://www.fakecomplete.com"
106107 ),
@@ -425,7 +426,7 @@ async def test_clean_task_output_and_log_files_if_invalid(
425426 published_project : PublishedProject ,
426427 mocked_node_ports_filemanager_fcts : dict [str , mock .MagicMock ],
427428 create_simcore_file_id : Callable [[ProjectID , NodeID , str ], SimcoreS3FileID ],
428- entry_exists_returns : bool , # noqa: FBT001
429+ entry_exists_returns : bool ,
429430 fake_io_schema : dict [str , dict [str , str ]],
430431 faker : Faker ,
431432):
@@ -527,11 +528,6 @@ def test__to_human_readable_resource_values(
527528 )
528529
529530
530- @pytest .fixture
531- def cluster_id (faker : Faker ) -> ClusterID :
532- return faker .pyint (min_value = 0 )
533-
534-
535531@pytest .fixture
536532def _app_config_with_dask_client (
537533 _app_config_with_db : None ,
@@ -549,7 +545,6 @@ async def test_check_if_cluster_is_able_to_run_pipeline(
549545 _app_config_with_dask_client : None ,
550546 project_id : ProjectID ,
551547 node_id : NodeID ,
552- cluster_id : ClusterID ,
553548 published_project : PublishedProject ,
554549 initialized_app : FastAPI ,
555550):
@@ -563,7 +558,6 @@ async def test_check_if_cluster_is_able_to_run_pipeline(
563558 check_if_cluster_is_able_to_run_pipeline (
564559 project_id = project_id ,
565560 node_id = node_id ,
566- cluster_id = cluster_id ,
567561 node_image = sleeper_task .image ,
568562 scheduler_info = dask_client .backend .client .scheduler_info (),
569563 task_resources = {},
0 commit comments