1010from models_library .api_schemas_long_running_tasks .base import ProgressPercent
1111from models_library .api_schemas_webserver .projects import ProjectGet
1212from models_library .projects import ProjectID
13- from models_library .projects_nodes_io import NodeID , NodeIDStr
13+ from models_library .projects_nodes_io import NodeID
1414from models_library .projects_state import ProjectStatus
1515from models_library .users import UserID
1616from models_library .utils .fastapi_encoders import jsonable_encoder
@@ -155,9 +155,10 @@ async def _copy_files_from_source_project(
155155 user_id : UserID ,
156156 task_progress : TaskProgress ,
157157):
158- db : ProjectDBAPI = ProjectDBAPI .get_from_app_context (app )
158+ _projects_repository = ProjectDBAPI .get_from_app_context (app )
159+
159160 needs_lock_source_project : bool = (
160- await db .get_project_type (
161+ await _projects_repository .get_project_type (
161162 TypeAdapter (ProjectID ).validate_python (source_project ["uuid" ])
162163 )
163164 != ProjectTypeDB .TEMPLATE
@@ -263,7 +264,7 @@ async def create_project( # pylint: disable=too-many-arguments,too-many-branche
263264 """
264265 assert request .app # nosec
265266
266- db : ProjectDBAPI = ProjectDBAPI .get_from_app_context (request .app )
267+ _projects_repository = ProjectDBAPI .get_from_app_context (request .app )
267268
268269 new_project : ProjectDict = {}
269270 copy_file_coro = None
@@ -340,7 +341,7 @@ async def create_project( # pylint: disable=too-many-arguments,too-many-branche
340341 )
341342
342343 # 3.1 save new project in DB
343- new_project = await db .insert_project (
344+ new_project = await _projects_repository .insert_project (
344345 project = jsonable_encoder (new_project ),
345346 user_id = user_id ,
346347 product_name = product_name ,
@@ -376,7 +377,7 @@ async def create_project( # pylint: disable=too-many-arguments,too-many-branche
376377
377378 # 5. unhide the project if needed since it is now complete
378379 if not new_project_was_hidden_before_data_was_copied :
379- await db .set_hidden_flag (new_project ["uuid" ], hidden = False )
380+ await _projects_repository .set_hidden_flag (new_project ["uuid" ], hidden = False )
380381
381382 # update the network information in director-v2
382383 await dynamic_scheduler_api .update_projects_networks (
@@ -389,7 +390,7 @@ async def create_project( # pylint: disable=too-many-arguments,too-many-branche
389390 request .app , user_id , new_project ["uuid" ], product_name
390391 )
391392 # get the latest state of the project (lastChangeDate for instance)
392- new_project , _ = await db .get_project (project_uuid = new_project ["uuid" ])
393+ new_project , _ = await _projects_repository .get_project (project_uuid = new_project ["uuid" ])
393394 # Appends state
394395 new_project = await projects_service .add_project_states_for_user (
395396 user_id = user_id ,
@@ -403,7 +404,7 @@ async def create_project( # pylint: disable=too-many-arguments,too-many-branche
403404 await update_or_pop_permalink_in_project (request , new_project )
404405
405406 # Adds folderId
406- user_specific_project_data_db = await db .get_user_specific_project_data_db (
407+ user_specific_project_data_db = await _projects_repository .get_user_specific_project_data_db (
407408 project_uuid = new_project ["uuid" ],
408409 private_workspace_user_id_or_none = user_id if workspace_id is None else None ,
409410 )
0 commit comments