Merge branch 'main' into feat/rag-2

api/core/workflow/nodes/llm/node.py

@@ -5,7 +5,7 @@ import logging
 from collections.abc import Generator, Mapping, Sequence
 from typing import TYPE_CHECKING, Any, Optional
 
-from core.app.entities.app_invoke_entities import ModelConfigWithCredentialsEntity
+from core.app.entities.app_invoke_entities import InvokeFrom, ModelConfigWithCredentialsEntity
 from core.file import FileType, file_manager
 from core.helper.code_executor import CodeExecutor, CodeLanguage
 from core.llm_generator.output_parser.errors import OutputParserError
@@ -194,6 +194,17 @@ class LLMNode(BaseNode):
                 else []
             )
 
+            # single step run fetch file from sys files
+            if not files and self.invoke_from == InvokeFrom.DEBUGGER and not self.previous_node_id:
+                files = (
+                    llm_utils.fetch_files(
+                        variable_pool=variable_pool,
+                        selector=["sys", "files"],
+                    )
+                    if self._node_data.vision.enabled
+                    else []
+                )
+
             if files:
                 node_inputs["#files#"] = [file.to_dict() for file in files]
 

api/core/workflow/workflow_type_encoder.py

@@ -1,4 +1,5 @@
 from collections.abc import Mapping
+from decimal import Decimal
 from typing import Any
 
 from pydantic import BaseModel
@@ -17,6 +18,9 @@ class WorkflowRuntimeTypeConverter:
             return value
         if isinstance(value, (bool, int, str, float)):
             return value
+        if isinstance(value, Decimal):
+            # Convert Decimal to float for JSON serialization
+            return float(value)
         if isinstance(value, Segment):
             return self._to_json_encodable_recursive(value.value)
         if isinstance(value, File):