From 09e0a540705c4d85a4214977718dba5e467fef2a Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Thu, 19 Jun 2025 10:38:10 +0800 Subject: [PATCH 1/2] r2 --- api/controllers/console/datasets/datasets_document.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/api/controllers/console/datasets/datasets_document.py b/api/controllers/console/datasets/datasets_document.py index e5fde58d04..ccd19a546b 100644 --- a/api/controllers/console/datasets/datasets_document.py +++ b/api/controllers/console/datasets/datasets_document.py @@ -1144,3 +1144,5 @@ api.add_resource(DocumentRetryApi, "/datasets//retry") api.add_resource(DocumentRenameApi, "/datasets//documents//rename") api.add_resource(WebsiteDocumentSyncApi, "/datasets//documents//website-sync") +api.add_resource(DocumentPipelineExecutionLogApi, + "/datasets//documents//pipeline-execution-log") From 6ec742539a50eb599781cefbacbd318ee35f3a0b Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Thu, 19 Jun 2025 10:45:59 +0800 Subject: [PATCH 2/2] r2 --- api/controllers/console/datasets/datasets_document.py | 3 ++- api/core/app/apps/pipeline/pipeline_generator.py | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/api/controllers/console/datasets/datasets_document.py b/api/controllers/console/datasets/datasets_document.py index ccd19a546b..16a00bbd42 100644 --- a/api/controllers/console/datasets/datasets_document.py +++ b/api/controllers/console/datasets/datasets_document.py @@ -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 diff --git a/api/core/app/apps/pipeline/pipeline_generator.py b/api/core/app/apps/pipeline/pipeline_generator.py index e726ad4841..49831007ee 100644 --- a/api/core/app/apps/pipeline/pipeline_generator.py +++ b/api/core/app/apps/pipeline/pipeline_generator.py @@ -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,