From ea38b4bcbeeddcb12e6ffe61184635173af311ab Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Wed, 17 Sep 2025 23:15:03 +0800 Subject: [PATCH 1/2] fix mypy --- .../service_api/dataset/rag_pipeline/rag_pipeline_workflow.py | 2 +- api/core/datasource/datasource_manager.py | 2 +- api/core/workflow/nodes/loop/loop_node.py | 4 +++- 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/api/controllers/service_api/dataset/rag_pipeline/rag_pipeline_workflow.py b/api/controllers/service_api/dataset/rag_pipeline/rag_pipeline_workflow.py index cbc1907bf5..f05325d711 100644 --- a/api/controllers/service_api/dataset/rag_pipeline/rag_pipeline_workflow.py +++ b/api/controllers/service_api/dataset/rag_pipeline/rag_pipeline_workflow.py @@ -215,7 +215,7 @@ class KnowledgebasePipelineFileUploadApi(DatasetApiResource): if not file.filename: raise FilenameNotExistsError - + if not current_user: raise ValueError("Invalid user account") diff --git a/api/core/datasource/datasource_manager.py b/api/core/datasource/datasource_manager.py index 31f982e960..47d297e194 100644 --- a/api/core/datasource/datasource_manager.py +++ b/api/core/datasource/datasource_manager.py @@ -84,7 +84,7 @@ class DatasourceManager: if controller is None: raise DatasourceProviderNotFoundError(f"Datasource provider {provider_id} not found.") - + return controller @classmethod diff --git a/api/core/workflow/nodes/loop/loop_node.py b/api/core/workflow/nodes/loop/loop_node.py index d783290e51..2b988ad944 100644 --- a/api/core/workflow/nodes/loop/loop_node.py +++ b/api/core/workflow/nodes/loop/loop_node.py @@ -92,7 +92,9 @@ class LoopNode(Node): if self._node_data.loop_variables: value_processor: dict[Literal["constant", "variable"], Callable[[LoopVariableData], Segment | None]] = { "constant": lambda var: self._get_segment_for_constant(var.var_type, var.value), - "variable": lambda var: self.graph_runtime_state.variable_pool.get(var.value) if isinstance(var.value, list) else None, + "variable": lambda var: self.graph_runtime_state.variable_pool.get(var.value) + if isinstance(var.value, list) + else None, } for loop_variable in self._node_data.loop_variables: if loop_variable.value_type not in value_processor: From 42d76dd12688a07351d1e43310d2f26b8fa45f76 Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Wed, 17 Sep 2025 23:19:57 +0800 Subject: [PATCH 2/2] fix mypy --- api/configs/__init__.py | 2 +- api/configs/feature/__init__.py | 4 ++-- api/core/workflow/errors.py | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/api/configs/__init__.py b/api/configs/__init__.py index 04642b5e9a..1932046322 100644 --- a/api/configs/__init__.py +++ b/api/configs/__init__.py @@ -1,3 +1,3 @@ from .app_config import DifyConfig -dify_config = DifyConfig() # pyright: ignore[reportCallIssue] +dify_config = DifyConfig() # type: ignore diff --git a/api/configs/feature/__init__.py b/api/configs/feature/__init__.py index 6d3934a557..db6f1e592c 100644 --- a/api/configs/feature/__init__.py +++ b/api/configs/feature/__init__.py @@ -512,11 +512,11 @@ class WorkflowVariableTruncationConfig(BaseSettings): description="Maximum size for variable to trigger final truncation.", ) WORKFLOW_VARIABLE_TRUNCATION_STRING_LENGTH: PositiveInt = Field( - 50000, + 100000, description="maximum length for string to trigger tuncation, measure in number of characters", ) WORKFLOW_VARIABLE_TRUNCATION_ARRAY_LENGTH: PositiveInt = Field( - 100, + 1000, description="maximum length for array to trigger truncation.", ) diff --git a/api/core/workflow/errors.py b/api/core/workflow/errors.py index 14e0315846..5bf1faee5d 100644 --- a/api/core/workflow/errors.py +++ b/api/core/workflow/errors.py @@ -13,4 +13,4 @@ class WorkflowNodeRunFailedError(Exception): @property def error(self) -> str: - return self._error \ No newline at end of file + return self._error