From 8bf7bbd4d051e7552b9b5cd3eb03ed096ffb4572 Mon Sep 17 00:00:00 2001 From: zhangzhanwei Date: Tue, 25 Nov 2025 15:27:09 +0800 Subject: [PATCH] feat: Alter fork depth --- .../data_source_web_node/impl/base_data_source_web_node.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py b/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py index 9fb163fe1d6..5943b3c3e48 100644 --- a/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py +++ b/apps/application/flow/step_node/data_source_web_node/impl/base_data_source_web_node.py @@ -61,7 +61,7 @@ def execute(self, **kwargs) -> NodeResult: collect_handler, document_list = get_collect_handler() try: - ForkManage(source_url,selector.split(" ") if selector is not None else []).fork(1,set(),collect_handler) + ForkManage(source_url,selector.split(" ") if selector is not None else []).fork(3,set(),collect_handler) return NodeResult({'document_list': document_list}, self.workflow_manage.params.get('knowledge_base') or {})