mirror of https://github.com/langgenius/dify.git
sign single step files
This commit is contained in:
parent
c3d926e2ed
commit
c70d0546ae
|
|
@ -4,6 +4,7 @@ from typing import Optional
|
|||
|
||||
from core.app.apps.base_app_queue_manager import GenerateTaskStoppedException
|
||||
from core.file.file_obj import FileVar
|
||||
from core.tools.tool_file_manager import ToolFileManager
|
||||
from core.workflow.callbacks.base_workflow_callback import BaseWorkflowCallback
|
||||
from core.workflow.entities.node_entities import NodeRunMetadataKey, NodeRunResult, NodeType
|
||||
from core.workflow.entities.variable_pool import VariablePool, VariableValue
|
||||
|
|
@ -258,11 +259,13 @@ class WorkflowEngineManager:
|
|||
variable_key_list=variable_key_list,
|
||||
value=user_inputs.get(variable_key)
|
||||
)
|
||||
|
||||
# run node
|
||||
node_run_result = node_instance.run(
|
||||
variable_pool=variable_pool
|
||||
)
|
||||
|
||||
# sign output files
|
||||
node_run_result.outputs = self.handle_special_values(node_run_result.outputs)
|
||||
except Exception as e:
|
||||
raise WorkflowNodeRunFailedError(
|
||||
node_id=node_instance.node_id,
|
||||
|
|
|
|||
Loading…
Reference in New Issue