This commit is contained in:
jyong 2025-06-19 10:45:59 +08:00
parent 09e0a54070
commit 6ec742539a
2 changed files with 3 additions and 2 deletions

View File

@ -1,3 +1,4 @@
import json
import logging
from argparse import ArgumentTypeError
from datetime import UTC, datetime
@ -1116,7 +1117,7 @@ class DocumentPipelineExecutionLogApi(DocumentResource):
if not log:
return {"datasource_info": None, "datasource_type": None, "input_data": None}, 200
return {
"datasource_info": log.datasource_info,
"datasource_info": json.loads(log.datasource_info),
"datasource_type": log.datasource_type,
"input_data": log.input_data,
}, 200

View File

@ -140,7 +140,7 @@ class PipelineGenerator(BaseAppGenerator):
document_pipeline_execution_log = DocumentPipelineExecutionLog(
document_id=document_id,
datasource_type=datasource_type,
datasource_info=datasource_info,
datasource_info=json.dumps(datasource_info),
input_data=inputs,
pipeline_id=pipeline.id,
created_by=user.id,