Skip to content

Commit 6c0431f

Browse files
fix: inputs required
1 parent c69df79 commit 6c0431f

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

packages/postgres-database/src/simcore_postgres_database/utils_projects_nodes.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ class ProjectNodeCreate(BaseModel):
6161
input_access: dict[str, Any] | None = None
6262
input_nodes: list[str] | None = None
6363
inputs: dict[str, Any] | None = None
64+
inputs_required: list[str] | None = None
6465
inputs_units: dict[str, Any] | None = None
6566
output_nodes: list[str] | None = None
6667
outputs: dict[str, Any] | None = None

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -312,6 +312,7 @@ async def insert_project(
312312
field_mapping = {
313313
"inputAccess": "input_access",
314314
"inputNodes": "input_nodes",
315+
"inputsRequired": "inputs_required",
315316
"inputsUnits": "inputs_units",
316317
"outputNodes": "output_nodes",
317318
"runHash": "run_hash",

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -679,11 +679,11 @@ async def _check_project_node_has_all_required_inputs(
679679
permission="read",
680680
)
681681

682-
project_dict, _ = await db.get_project_dict_and_type(f"{project_uuid}")
682+
nodes = await _projects_nodes_repository.get_by_project(
683+
app, project_id=project_uuid
684+
)
683685

684-
nodes_map: dict[NodeID, Node] = {
685-
NodeID(k): Node(**v) for k, v in project_dict["workbench"].items()
686-
}
686+
nodes_map = dict(nodes)
687687
node = nodes_map[node_id]
688688

689689
unset_required_inputs: list[str] = []

0 commit comments

Comments
 (0)