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 {})