Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -1047,13 +1047,17 @@ async def patch_project_node(
if _node_patch_exclude_unset.get("label"):
await dynamic_scheduler_api.update_projects_networks(app, project_id=project_id)

# 5. Updates project states for user, if inputs have been changed
if "inputs" in _node_patch_exclude_unset:
# 5. Updates project states for user, if inputs/outputs have been changed
if {"inputs", "outputs"} & _node_patch_exclude_unset.keys():
updated_project = await add_project_states_for_user(
user_id=user_id, project=updated_project, is_template=False, app=app
)
for node_uuid in updated_project["workbench"]:
await notify_project_node_update(
app, updated_project, node_uuid, errors=None
)
return

# 6. Notify project node update
await notify_project_node_update(app, updated_project, node_id, errors=None)


Expand Down
Loading