yujunjun/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2025-12-27 10:02:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

r2 transform

Browse Source
This commit is contained in:
jyong 2025-07-17 16:45:30 +08:00
parent ad7650e724
commit cc96b7f507
1 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
api/services/rag_pipeline/rag_pipeline_transform_service.py
View File

@ -247,25 +247,6 @@ class RagPipelineTransformService:
plugin_unique_identifier = dependency.get("value", {}).get("plugin_unique_identifier")
plugin_id = plugin_unique_identifier.split(":")[0]
if plugin_id not in installed_plugins_ids:
# if plugin_id == "langgenius/notion_datasource":
# datasource = plugin_migration._fetch_plugin_unique_identifier(f"{plugin_id}/notion")
# need_install_plugin_unique_identifiers.append(datasource.plugin_unique_identifier)
# elif plugin_id == "langgenius/firecrawl_datasource":
# datasource = datasource_manager.fetch_datasource_provider(tenant_id, f"{plugin_id}/firecrawl")
# need_install_plugin_unique_identifiers.append(datasource.plugin_unique_identifier)
# elif plugin_id == "langgenius/jina_datasource":
# datasource = datasource_manager.fetch_datasource_provider(tenant_id, f"{plugin_id}/jina")
# need_install_plugin_unique_identifiers.append(datasource.plugin_unique_identifier)
# elif plugin_id == "langgenius/dify_extractor":
# tool = tool_manager.get_plugin_provider(f"{plugin_id}/dify_extractor", tenant_id)
# need_install_plugin_unique_identifiers.append(tool.plugin_unique_identifier)
# elif plugin_id == "langgenius/general_chunker":
# tool = tool_manager.get_plugin_provider(f"{plugin_id}/general_chunker", tenant_id)
# need_install_plugin_unique_identifiers.append(tool.plugin_unique_identifier)
# elif plugin_id == "langgenius/parentchild_chunker":
# tool = tool_manager.get_plugin_provider(f"{plugin_id}/parentchild_chunker", tenant_id)
# need_install_plugin_unique_identifiers.append(tool.plugin_unique_identifier)
# dependency["value"]["current_identifier"] = plugin_unique_identifier
plugin_unique_identifier = plugin_migration._fetch_plugin_unique_identifier(plugin_id)
if plugin_unique_identifier:
need_install_plugin_unique_identifiers.append(plugin_unique_identifier)