record inputs and process data when node failed

This commit is contained in:
takatost
2024-03-13 14:55:56 +08:00
parent da3e1e9d14
commit 2b4b6817a3
7 changed files with 29 additions and 14 deletions

View File

@ -96,7 +96,9 @@ class WorkflowEventTriggerCallback(BaseWorkflowCallback):
def on_workflow_node_execute_failed(self, node_id: str,
node_type: NodeType,
node_data: BaseNodeData,
error: str) -> None:
error: str,
inputs: Optional[dict] = None,
process_data: Optional[dict] = None) -> None:
"""
Workflow node execute failed
"""
@ -105,6 +107,8 @@ class WorkflowEventTriggerCallback(BaseWorkflowCallback):
node_id=node_id,
node_type=node_type,
node_data=node_data,
inputs=inputs,
process_data=process_data,
error=error
),
PublishFrom.APPLICATION_MANAGER