fix json workflow parameter validation bug (#1030)

This commit is contained in:
Shuchang Zheng
2024-10-22 22:35:14 -07:00
committed by GitHub
parent 51a531df09
commit d81fcaa932

View File

@@ -569,13 +569,14 @@ class WorkflowService:
workflow_parameter: WorkflowParameter,
value: Any,
) -> WorkflowRunParameter:
value = json.dumps(value) if isinstance(value, (dict, list)) else value
# InvalidWorkflowParameter will be raised if the validation fails
workflow_parameter.workflow_parameter_type.convert_value(value)
return await app.DATABASE.create_workflow_run_parameter(
workflow_run_id=workflow_run_id,
workflow_parameter=workflow_parameter,
value=json.dumps(value) if isinstance(value, (dict, list)) else value,
value=value,
)
async def get_workflow_run_parameter_tuples(