fix: Fix the wrong result of not_contain_compare when source_value is a list (#5152)

* perf: system prompt double-generating

* fix: Fix some minor problem

* fix

* 小调整。

* 文件处理，使用 with ... as file 语法，避免文件未关闭。

* 修正错误字符串

* fix bugs: invalid regex escape sequences, and resource leaks

* fix bugs: invalid regex escape sequences, and resource leaks

* 撤回对正则的修正。

* operation

* 小调整

* 小调整

* 小调整

* revert

* revert

* 小调整。

* 小调整。

* 小调整.

* revert

* fix: Fix `not_contain` compare

* fix style

* revert

* revert

Author: wangliang181230

apps/application/chat_pipeline/step/chat_step/impl/base_chat_step.py

@@ -185,8 +185,7 @@ def execute(self, message_list: List[BaseMessage],
                 mcp_output_enable=True,
                 **kwargs):
         chat_model = get_model_instance_by_model_workspace_id(model_id, workspace_id,
-                                                              **(
-                                                                      model_params_setting or {})) if model_id is not None else None
+                                                              **(model_params_setting or {})) if model_id is not None else None
         if stream:
             return self.execute_stream(message_list, chat_id, problem_text, post_response_handler, chat_model,
                                        paragraph_list,

apps/application/flow/compare/not_contain_compare.py

@@ -20,7 +20,7 @@ def support(self, node_id, fields: List[str], source_value, compare, target_valu
     def compare(self, source_value, compare, target_value):
         if isinstance(source_value, str):
             return str(target_value) not in source_value
-        elif isinstance(self, list):
+        elif isinstance(source_value, list):
             return not any([str(item) == str(target_value) for item in source_value])
         else:
             return str(target_value) not in str(source_value)

apps/application/flow/step_node/tool_lib_node/impl/base_tool_lib_node.py

@@ -110,7 +110,8 @@ def convert_value(name: str, value, _type, is_required, source, node):
         if _type == 'int':
             return int(value)
         if _type == 'boolean':
-            value = 0 if ['0', '[]'].__contains__(value) else value
+            if isinstance(value, str) and value.lower() in ('false', '0', '[]', ''):
+                return False
             return bool(value)
         if _type == 'float':
             return float(value)

apps/application/flow/step_node/tool_node/impl/base_tool_node.py

@@ -85,7 +85,8 @@ def convert_value(name: str, value, _type, is_required, source, node):
         if _type == 'int':
             return int(value)
         if _type == 'boolean':
-            value = 0 if ['0', '[]'].__contains__(value) else value
+            if isinstance(value, str) and value.lower() in ('false', '0', '[]', ''):
+                return False
             return bool(value)
         if _type == 'float':
             return float(value)

apps/knowledge/views/paragraph.py

@@ -64,7 +64,6 @@ def get(self, request: Request, workspace_id: str, knowledge_id: str, document_i
     @log(
         menu='Paragraph', operate='Create Paragraph',
         get_operation_object=lambda r, keywords: get_knowledge_document_operation_object(
-            get_knowledge_operation_object(keywords.get('knowledge_id')),
             get_knowledge_operation_object(keywords.get('knowledge_id')),
             get_document_operation_object(keywords.get('document_id'))
         ),

apps/tools/serializers/tool.py

@@ -536,7 +536,8 @@ def convert_value(name: str, value: str, _type: str, is_required: bool):
                 if _type == 'int':
                     return int(value)
                 if _type == 'boolean':
-                    value = 0 if ['0', '[]'].__contains__(value) else value
+                    if isinstance(value, str) and value.lower() in ('false', '0', '[]', ''):
+                        return False
                     return bool(value)
                 if _type == 'float':
                     return float(value)

apps/trigger/handler/impl/task/tool_task/base_tool_task.py

@@ -50,7 +50,8 @@ def _convert_value(_type, value):
     if _type == 'int':
         return int(value)
     if _type == 'boolean':
-        value = 0 if ['0', '[]'].__contains__(value) else value
+        if isinstance(value, str) and value.lower() in ('false', '0', '[]', ''):
+            return False
         return bool(value)
     if _type == 'float':
         return float(value)

apps/trigger/handler/impl/task/tool_task/workflow_tool_task.py

@@ -52,7 +52,8 @@ def _convert_value(_type, value):
     if _type == 'int':
         return int(value)
     if _type == 'boolean':
-        value = 0 if ['0', '[]'].__contains__(value) else value
+        if isinstance(value, str) and value.lower() in ('false', '0', '[]', ''):
+            return False
         return bool(value)
     if _type == 'float':
         return float(value)

apps/trigger/handler/impl/trigger/scheduled_trigger.py

@@ -243,11 +243,11 @@ def execute(trigger, **kwargs):
         if source_type == "APPLICATION":
             from trigger.handler.impl.task.application_task import ApplicationTask
 
-            ApplicationTask.execute(trigger_task, **kwargs)
+            ApplicationTask().execute(trigger_task, **kwargs)
         elif source_type == "TOOL":
             from trigger.handler.impl.task.tool_task import ToolTask
 
-            ToolTask.execute(trigger_task, **kwargs)
+            ToolTask().execute(trigger_task, **kwargs)
         else:
             maxkb_logger.warning(f"unsupported source_type={source_type}, task_id={trigger_task['id']}")
 

ui/src/workflow/common/NodeSearch.vue

@@ -217,7 +217,6 @@ const handleSearch = (kw: string) => {
   }
 }
 const reSearch = () => {
-  console.log('ss')
   handleSearch(searchText.value)
 }
 // 生命周期