From fcbd5febeb7851e1444a653e175c85958ea17546 Mon Sep 17 00:00:00 2001
From: jyong <718720800@qq.com>
Date: Fri, 6 Jun 2025 17:47:06 +0800
Subject: [PATCH] r2

---
 api/services/rag_pipeline/rag_pipeline.py | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/api/services/rag_pipeline/rag_pipeline.py b/api/services/rag_pipeline/rag_pipeline.py
index 1d4e279d2a..7f5d4de7e3 100644
--- a/api/services/rag_pipeline/rag_pipeline.py
+++ b/api/services/rag_pipeline/rag_pipeline.py
@@ -422,7 +422,7 @@ class RagPipelineService:
         Run published workflow datasource
         """
         if is_published:
-        # fetch published workflow by app_model
+            # fetch published workflow by app_model
             workflow = self.get_published_workflow(pipeline=pipeline)
         else:
             workflow = self.get_draft_workflow(pipeline=pipeline)
@@ -440,7 +440,6 @@ class RagPipelineService:
         if not datasource_node_data:
             raise ValueError("Datasource node data not found")
 
-
         from core.datasource.datasource_manager import DatasourceManager
 
         datasource_runtime = DatasourceManager.get_datasource_runtime(
@@ -474,16 +473,16 @@ class RagPipelineService:
                 }
             case _:
                 raise ValueError(f"Unsupported datasource provider: {datasource_runtime.datasource_provider_type}")
-            
 
     def run_datasource_workflow_node(
-        self, pipeline: Pipeline, node_id: str, user_inputs: dict, account: Account, datasource_type: str, is_published: bool
+        self, pipeline: Pipeline, node_id: str, user_inputs: dict, account: Account, datasource_type: str,
+        is_published: bool
     ) -> dict:
         """
         Run published workflow datasource
         """
         if is_published:
-        # fetch published workflow by app_model
+            # fetch published workflow by app_model
             workflow = self.get_published_workflow(pipeline=pipeline)
         else:
             workflow = self.get_draft_workflow(pipeline=pipeline)
@@ -544,6 +543,8 @@ class RagPipelineService:
                 )
                 return {
                     "result": [result.model_dump() for result in website_crawl_result.result],
+                    "job_id": website_crawl_result.job_id,
+                    "status": website_crawl_result.status,
                     "provider_type": datasource_node_data.get("provider_type"),
                 }
             case _: