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/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: