fix: fix WorkflowExecution.outputs containing non-JSON-serializable o…

api/configs/middleware/vdb/milvus_config.py

@@ -16,7 +16,6 @@ class MilvusConfig(BaseSettings):
  description="Authentication token for Milvus, if token-based authentication is enabled",
  default=None,
  )
-
  MILVUS_USER: str | None = Field(
  description="Username for authenticating with Milvus, if username/password authentication is enabled",
  default=None,

api/extensions/logstore/repositories/logstore_workflow_execution_repository.py

@@ -22,6 +22,18 @@
 logger = logging.getLogger(__name__)
 
 
+def to_serializable(obj):
+ """
+ Convert non-JSON-serializable objects into JSON-compatible formats.
+
+ - Uses `to_dict()` if it's a callable method.
+ - Falls back to string representation.
+ """
+ if hasattr(obj, "to_dict") and callable(obj.to_dict):
+ return obj.to_dict()
+ return str(obj)
+
+
 class LogstoreWorkflowExecutionRepository(WorkflowExecutionRepository):
  def __init__(
  self,
@@ -108,9 +120,24 @@ def _to_logstore_model(self, domain_model: WorkflowExecution) -> list[tuple[str,
  ),
  ("type", domain_model.workflow_type.value),
  ("version", domain_model.workflow_version),
- ("graph", json.dumps(domain_model.graph, ensure_ascii=False) if domain_model.graph else "{}"),
- ("inputs", json.dumps(domain_model.inputs, ensure_ascii=False) if domain_model.inputs else "{}"),
- ("outputs", json.dumps(domain_model.outputs, ensure_ascii=False) if domain_model.outputs else "{}"),
+ (
+ "graph",
+ json.dumps(domain_model.graph, ensure_ascii=False, default=to_serializable)
+ if domain_model.graph
+ else "{}",
+ ),
+ (
+ "inputs",
+ json.dumps(domain_model.inputs, ensure_ascii=False, default=to_serializable)
+ if domain_model.inputs
+ else "{}",
+ ),
+ (
+ "outputs",
+ json.dumps(domain_model.outputs, ensure_ascii=False, default=to_serializable)
+ if domain_model.outputs
+ else "{}",
+ ),
  ("status", domain_model.status.value),
  ("error_message", domain_model.error_message or ""),
  ("total_tokens", str(domain_model.total_tokens)),