allow to patch inputs and outputs of function jobs

Author: bisgaard-itis

packages/models-library/src/models_library/functions.py

@@ -179,6 +179,8 @@ class RegisteredProjectFunctionJobPatch(BaseModel):
     function_class: Literal[FunctionClass.PROJECT] = FunctionClass.PROJECT
     title: str | None
     description: str | None
+    inputs: FunctionInputs
+    outputs: FunctionOutputs
     project_job_id: ProjectID | None
     job_creation_task_id: TaskID | None
 
@@ -197,6 +199,8 @@ class RegisteredSolverFunctionJobPatch(BaseModel):
     function_class: Literal[FunctionClass.SOLVER] = FunctionClass.SOLVER
     title: str | None
     description: str | None
+    inputs: FunctionInputs
+    outputs: FunctionOutputs
     solver_job_id: ProjectID | None
     job_creation_task_id: TaskID | None
 
@@ -212,6 +216,8 @@ class RegisteredPythonCodeFunctionJob(PythonCodeFunctionJob, RegisteredFunctionJ
 class RegisteredPythonCodeFunctionJobPatch(BaseModel):
     function_class: Literal[FunctionClass.PYTHON_CODE] = FunctionClass.PYTHON_CODE
     title: str | None
+    inputs: FunctionInputs
+    outputs: FunctionOutputs
     description: str | None
 
 

services/web/server/src/simcore_service_webserver/functions/_functions_service.py

@@ -802,8 +802,8 @@ def _patch_functionjob(
             title=patch.title or function_job_db.title,
             uuid=function_job_db.uuid,
             description=patch.description or function_job_db.description,
-            inputs=function_job_db.inputs,
-            outputs=function_job_db.outputs,
+            inputs=patch.inputs or function_job_db.inputs,
+            outputs=patch.outputs or function_job_db.outputs,
             created=function_job_db.created,
             class_specific_data=FunctionClassSpecificData(
                 project_job_id=(
@@ -826,8 +826,8 @@ def _patch_functionjob(
             title=patch.title or function_job_db.title,
             uuid=function_job_db.uuid,
             description=patch.description or function_job_db.description,
-            inputs=function_job_db.inputs,
-            outputs=function_job_db.outputs,
+            inputs=patch.inputs or function_job_db.inputs,
+            outputs=patch.outputs or function_job_db.outputs,
             created=function_job_db.created,
             class_specific_data=FunctionClassSpecificData(
                 solver_job_id=(
@@ -850,8 +850,8 @@ def _patch_functionjob(
             title=patch.title or function_job_db.title,
             uuid=function_job_db.uuid,
             description=patch.description or function_job_db.description,
-            inputs=function_job_db.inputs,
-            outputs=function_job_db.outputs,
+            inputs=patch.inputs or function_job_db.inputs,
+            outputs=patch.outputs or function_job_db.outputs,
             created=function_job_db.created,
             class_specific_data=function_job_db.class_specific_data,
         )

services/web/server/tests/unit/with_dbs/04/functions/test_function_jobs_controller_rpc.py

@@ -464,8 +464,8 @@ async def test_patch_registered_function_jobs(
         title="Test Function Job",
         description="A test function job",
         project_job_id=None,
-        inputs={"input1": _faker.pyint(min_value=0, max_value=1000)},
-        outputs={"output1": "result1"},
+        inputs=None,
+        outputs=None,
         job_creation_task_id=None,
     )
 
@@ -482,6 +482,8 @@ async def test_patch_registered_function_jobs(
         description=_faker.sentence(),
         project_job_id=ProjectID(_faker.uuid4()),
         job_creation_task_id=TaskID(_faker.uuid4()),
+        inputs={"input1": _faker.pyint(min_value=0, max_value=1000)},
+        outputs={"output1": _faker.word()},
     )
 
     registered_job = await functions_rpc.patch_registered_function_job(
@@ -494,6 +496,8 @@ async def test_patch_registered_function_jobs(
     assert registered_job.function_class == FunctionClass.PROJECT
     assert registered_job.title == patch.title
     assert registered_job.description == patch.description
+    assert registered_job.inputs == patch.inputs
+    assert registered_job.outputs == patch.outputs
     assert registered_job.job_creation_task_id == patch.job_creation_task_id
     assert registered_job.project_job_id == patch.project_job_id