From 9e0c28791ddd14cb9629e021ee837ce23d15a9b2 Mon Sep 17 00:00:00 2001 From: Novice Lee Date: Thu, 19 Dec 2024 14:46:19 +0800 Subject: [PATCH] fix: resolve code merge issues --- api/core/app/apps/workflow/generate_task_pipeline.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/api/core/app/apps/workflow/generate_task_pipeline.py b/api/core/app/apps/workflow/generate_task_pipeline.py index 94dd1b6e47..79e5e2bcb9 100644 --- a/api/core/app/apps/workflow/generate_task_pipeline.py +++ b/api/core/app/apps/workflow/generate_task_pipeline.py @@ -287,7 +287,8 @@ class WorkflowAppGenerateTaskPipeline(BasedGenerateTaskPipeline, WorkflowCycleMa task_id=self._application_generate_entity.task_id, workflow_node_execution=workflow_node_execution, ) - + if node_failed_response: + yield node_failed_response elif isinstance( event, QueueNodeRetryEvent, @@ -304,8 +305,7 @@ class WorkflowAppGenerateTaskPipeline(BasedGenerateTaskPipeline, WorkflowCycleMa if response: yield response - if node_failed_response: - yield node_failed_response + elif isinstance(event, QueueParallelBranchRunStartedEvent): if not workflow_run: raise Exception("Workflow run not initialized.")