Merge branch 'feat/workflow-backend' into deploy/dev

langgenius · Mar 14, 2024 · 71c5627 · 71c5627
2 parents 61aac32 + d85b5b9
commit 71c5627
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/api/core/workflow/nodes/tool/entities.py b/api/core/workflow/nodes/tool/entities.py
@@ -3,7 +3,6 @@
 from pydantic import BaseModel, validator
 
 from core.workflow.entities.base_node_data_entities import BaseNodeData
-from core.workflow.entities.variable_entities import VariableSelector
 
 ToolParameterValue = Union[str, int, float, bool]
 
@@ -16,15 +15,23 @@ class ToolEntity(BaseModel):
     tool_configurations: dict[str, ToolParameterValue]
 
 class ToolNodeData(BaseNodeData, ToolEntity):
-    class ToolInput(VariableSelector):
+    class ToolInput(BaseModel):
+        variable: str
         variable_type: Literal['selector', 'static']
+        value_selector: Optional[list[str]]
         value: Optional[str]
 
         @validator('value')
         def check_value(cls, value, values, **kwargs):
             if values['variable_type'] == 'static' and value is None:
                 raise ValueError('value is required for static variable')
             return value
+
+        @validator('value_selector')
+        def check_value_selector(cls, value_selector, values, **kwargs):
+            if values['variable_type'] == 'selector' and value_selector is None:
+                raise ValueError('value_selector is required for selector variable')
+            return value_selector
 
     """
     Tool Node Schema

diff --git a/api/core/workflow/nodes/tool/tool_node.py b/api/core/workflow/nodes/tool/tool_node.py
@@ -44,7 +44,7 @@ def _run(self, variable_pool: VariablePool) -> NodeRunResult:
             return NodeRunResult(
                 status=WorkflowNodeExecutionStatus.FAILED,
                 inputs=parameters,
-                error=f'Failed to invoke tool: {str(e)}'
+                error=f'Failed to invoke tool: {str(e)}',
             )
 
         # convert tool messages
@@ -56,6 +56,7 @@ def _run(self, variable_pool: VariablePool) -> NodeRunResult:
                 'text': plain_text,
                 'files': files
             },
+            inputs=parameters
         )
 
     def _generate_parameters(self, variable_pool: VariablePool, node_data: ToolNodeData) -> dict: