From 47bbd739fcbc3d06c6053af2944edefcf1e7f9ad Mon Sep 17 00:00:00 2001 From: -LAN- Date: Wed, 14 May 2025 14:54:19 +0800 Subject: [PATCH] refactor(sqlalchemy_workflow_node_execution_repository): Use xxx_dict properties in `_to_domain_model` Signed-off-by: -LAN- --- .../sqlalchemy_workflow_node_execution_repository.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/api/core/repositories/sqlalchemy_workflow_node_execution_repository.py b/api/core/repositories/sqlalchemy_workflow_node_execution_repository.py index 0715160171..f4c515ad45 100644 --- a/api/core/repositories/sqlalchemy_workflow_node_execution_repository.py +++ b/api/core/repositories/sqlalchemy_workflow_node_execution_repository.py @@ -98,10 +98,10 @@ class SQLAlchemyWorkflowNodeExecutionRepository(WorkflowNodeExecutionRepository) The domain model """ # Parse JSON fields - inputs = json.loads(db_model.inputs) if db_model.inputs else None - process_data = json.loads(db_model.process_data) if db_model.process_data else None - outputs = json.loads(db_model.outputs) if db_model.outputs else None - metadata = json.loads(db_model.execution_metadata) if db_model.execution_metadata else None + inputs = db_model.inputs_dict + process_data = db_model.process_data_dict + outputs = db_model.outputs_dict + metadata = db_model.execution_metadata_dict # Convert status to domain enum status = NodeExecutionStatus(db_model.status)