Skip to content

Commit 9a7c654

Browse files
remove get project
1 parent fba3af1 commit 9a7c654

File tree

2 files changed

+9
-15
lines changed

2 files changed

+9
-15
lines changed

services/web/server/src/simcore_service_webserver/projects/_controller/nodes_rest.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -111,18 +111,12 @@ async def create_node(request: web.Request) -> web.Response:
111111
text=f"Service {body.service_key}:{body.service_version} is deprecated"
112112
)
113113

114-
# ensure the project exists
115-
project_data = await _projects_service.get_project_for_user(
116-
request.app,
117-
project_uuid=f"{path_params.project_id}",
118-
user_id=req_ctx.user_id,
119-
)
120114
data = {
121115
"node_id": await _projects_service.add_project_node(
122116
request,
123-
project_data,
124117
req_ctx.user_id,
125118
req_ctx.product_name,
119+
path_params.project_id,
126120
get_api_base_url(request),
127121
body.service_key,
128122
body.service_version,

services/web/server/src/simcore_service_webserver/projects/_projects_service.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -935,9 +935,9 @@ async def _() -> None:
935935

936936
async def add_project_node(
937937
request: web.Request,
938-
project: dict[str, Any],
939938
user_id: UserID,
940939
product_name: str,
940+
project_id: ProjectID,
941941
product_api_base_url: str,
942942
service_key: ServiceKey,
943943
service_version: ServiceVersion,
@@ -948,14 +948,14 @@ async def add_project_node(
948948
"starting node %s:%s in project %s for user %s",
949949
service_key,
950950
service_version,
951-
project["uuid"],
951+
project_id,
952952
user_id,
953953
extra=get_log_record_extra(user_id=user_id),
954954
)
955955

956956
await check_user_project_permission(
957957
request.app,
958-
project_id=project["uuid"],
958+
project_id=project_id,
959959
user_id=user_id,
960960
product_name=product_name,
961961
permission="write",
@@ -968,7 +968,7 @@ async def add_project_node(
968968

969969
await _projects_nodes_repository.add(
970970
request.app,
971-
project_id=ProjectID(project["uuid"]),
971+
project_id=project_id,
972972
node_id=node_uuid,
973973
node=Node(
974974
key=service_key,
@@ -980,7 +980,7 @@ async def add_project_node(
980980

981981
await _create_project_document_and_notify(
982982
request.app,
983-
project_id=ProjectID(project["uuid"]),
983+
project_id=project_id,
984984
user_id=user_id,
985985
client_session_id=client_session_id,
986986
)
@@ -990,12 +990,12 @@ async def add_project_node(
990990
await director_v2_service.create_or_update_pipeline(
991991
request.app,
992992
user_id,
993-
project["uuid"],
993+
project_id,
994994
product_name,
995995
product_api_base_url,
996996
)
997997
await dynamic_scheduler_service.update_projects_networks(
998-
request.app, project_id=ProjectID(project["uuid"])
998+
request.app, project_id=project_id
999999
)
10001000

10011001
if _is_node_dynamic(service_key):
@@ -1008,7 +1008,7 @@ async def add_project_node(
10081008
product_name=product_name,
10091009
product_api_base_url=product_api_base_url,
10101010
user_id=user_id,
1011-
project_uuid=ProjectID(project["uuid"]),
1011+
project_uuid=project_id,
10121012
node_uuid=node_uuid,
10131013
)
10141014

0 commit comments

Comments
 (0)