feat(datasource): change datasource result type to event-stream

api/core/app/apps/pipeline/pipeline_generator.py

@@ -589,7 +589,7 @@ class PipelineGenerator(BaseAppGenerator):
         if datasource_type == "local_file":
             name = datasource_info["name"]
         elif datasource_type == "online_document":
-            name = datasource_info["page_title"]
+            name = datasource_info['page']["page_name"]
         elif datasource_type == "website_crawl":
             name = datasource_info["title"]
         else:

api/core/plugin/impl/datasource.py

@@ -170,7 +170,7 @@ class PluginDatasourceManager(BasePluginClient):
 
         datasource_provider_id = GenericProviderID(datasource_provider)
 
-        response = self._request_with_plugin_daemon_response_stream(
+        return self._request_with_plugin_daemon_response_stream(
             "POST",
             f"plugin/{tenant_id}/dispatch/datasource/get_online_document_page_content",
             DatasourceMessage,
@@ -188,7 +188,6 @@ class PluginDatasourceManager(BasePluginClient):
                 "Content-Type": "application/json",
             },
         )
-        yield from response
 
     def validate_provider_credentials(
         self, tenant_id: str, user_id: str, provider: str, plugin_id: str, credentials: dict[str, Any]