diff --git a/api/services/workflow_service.py b/api/services/workflow_service.py index d60c897f86..6f40dce18f 100644 --- a/api/services/workflow_service.py +++ b/api/services/workflow_service.py @@ -2,7 +2,7 @@ import json import time from collections.abc import Sequence from datetime import UTC, datetime -from typing import Any, Optional, cast +from typing import Optional, cast from uuid import uuid4 from core.app.apps.advanced_chat.app_config_manager import AdvancedChatAppConfigManager @@ -356,7 +356,7 @@ class WorkflowService: should_retry = True retries = 0 max_retries = 0 - retry_interval = 0 + retry_interval = 0.0 list_node_executions = [] while retries <= max_retries and should_retry: @@ -464,7 +464,10 @@ class WorkflowService: } if node_instance.node_data.error_strategy is ErrorStrategy.DEFAULT_VALUE: node_run_result = NodeRunResult( - **node_error_args, + status=WorkflowNodeExecutionStatus.EXCEPTION, + error=node_run_result.error, + inputs=node_run_result.inputs, + metadata={NodeRunMetadataKey.ERROR_STRATEGY: node_instance.node_data.error_strategy}, outputs={ **node_instance.node_data.default_value_dict, "error_message": node_run_result.error, @@ -473,7 +476,10 @@ class WorkflowService: ) else: node_run_result = NodeRunResult( - **node_error_args, + status=WorkflowNodeExecutionStatus.EXCEPTION, + error=node_run_result.error, + inputs=node_run_result.inputs, + metadata={NodeRunMetadataKey.ERROR_STRATEGY: node_instance.node_data.error_strategy}, outputs={ "error_message": node_run_result.error, "error_type": node_run_result.error_type,