@@ -1089,29 +1089,7 @@ async def add_project_node(
10891089 async with self .engine .acquire () as conn :
10901090 await project_nodes_repo .add (conn , nodes = [node ])
10911091
1092- async def remove_project_node (
1093- self ,
1094- user_id : UserID ,
1095- project_id : ProjectID ,
1096- node_id : NodeID ,
1097- client_session_id : ClientSessionID | None ,
1098- ) -> None :
1099- # NOTE: permission check is done currently in update_project_workbench!
1100- partial_workbench_data : dict [NodeIDStr , Any ] = {
1101- NodeIDStr (f"{ node_id } " ): None ,
1102- }
1103- await self ._update_project_workbench_with_lock_and_notify (
1104- partial_workbench_data ,
1105- user_id = user_id ,
1106- project_uuid = project_id ,
1107- allow_workbench_changes = True ,
1108- client_session_id = client_session_id ,
1109- )
1110- project_nodes_repo = ProjectNodesRepo (project_uuid = project_id )
1111- async with self .engine .acquire () as conn :
1112- await project_nodes_repo .delete (conn , node_id = node_id )
1113-
1114- async def get_project_node ( # NOTE: Not all Node data are here yet; they are in the workbench of a Project, waiting to be moved here.
1092+ async def get_project_node (
11151093 self , project_id : ProjectID , node_id : NodeID
11161094 ) -> ProjectNode :
11171095 project_nodes_repo = ProjectNodesRepo (project_uuid = project_id )
0 commit comments