opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-28 11:56:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

add pipeline async run

Browse Source
This commit is contained in:
jyong 2025-08-26 17:18:43 +08:00
parent 60fb242f27
commit 51c3f1b2e2
1 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,6 +16,7 @@ from models.model import UploadFile
from models.workflow import Workflow, WorkflowType from models.workflow import Workflow, WorkflowType
from services.entities.knowledge_entities.rag_pipeline_entities import KnowledgeConfiguration, RetrievalSetting from services.entities.knowledge_entities.rag_pipeline_entities import KnowledgeConfiguration, RetrievalSetting
from services.plugin.plugin_migration import PluginMigration from services.plugin.plugin_migration import PluginMigration
from services.plugin.plugin_service import PluginService
class RagPipelineTransformService: class RagPipelineTransformService:
@ -255,17 +256,7 @@ class RagPipelineTransformService:
need_install_plugin_unique_identifiers.append(plugin_unique_identifier) need_install_plugin_unique_identifiers.append(plugin_unique_identifier)
if need_install_plugin_unique_identifiers: if need_install_plugin_unique_identifiers:
print(need_install_plugin_unique_identifiers) print(need_install_plugin_unique_identifiers)
installer_manager.install_from_identifiers( PluginService.install_from_marketplace_pkg(tenant_id, need_install_plugin_unique_identifiers)
tenant_id,
need_install_plugin_unique_identifiers,
PluginInstallationSource.Marketplace,
metas=[
{
"plugin_unique_identifier": identifier,
}
for identifier in need_install_plugin_unique_identifiers
],
)
def _transfrom_to_empty_pipeline(self, dataset: Dataset): def _transfrom_to_empty_pipeline(self, dataset: Dataset):
pipeline = Pipeline( pipeline = Pipeline(