From cf2b5c7192a6f573d98df1d866d879d4763635bb Mon Sep 17 00:00:00 2001 From: -LAN- Date: Thu, 10 Jul 2025 14:26:28 +0800 Subject: [PATCH] refactor(workflow_response_converter): Remove unused workflow_execution_repository Signed-off-by: -LAN- --- api/core/app/apps/advanced_chat/generate_task_pipeline.py | 1 - api/core/app/apps/common/workflow_response_converter.py | 3 --- api/core/app/apps/workflow/generate_task_pipeline.py | 1 - 3 files changed, 5 deletions(-) diff --git a/api/core/app/apps/advanced_chat/generate_task_pipeline.py b/api/core/app/apps/advanced_chat/generate_task_pipeline.py index b177d49144..4c52fc3e83 100644 --- a/api/core/app/apps/advanced_chat/generate_task_pipeline.py +++ b/api/core/app/apps/advanced_chat/generate_task_pipeline.py @@ -138,7 +138,6 @@ class AdvancedChatAppGenerateTaskPipeline: self._workflow_response_converter = WorkflowResponseConverter( application_generate_entity=application_generate_entity, - workflow_execution_repository=workflow_execution_repository, ) self._task_state = WorkflowTaskState() diff --git a/api/core/app/apps/common/workflow_response_converter.py b/api/core/app/apps/common/workflow_response_converter.py index e027b4e470..34a1da2227 100644 --- a/api/core/app/apps/common/workflow_response_converter.py +++ b/api/core/app/apps/common/workflow_response_converter.py @@ -49,7 +49,6 @@ from core.workflow.entities.workflow_execution import WorkflowExecution from core.workflow.entities.workflow_node_execution import WorkflowNodeExecution, WorkflowNodeExecutionStatus from core.workflow.nodes import NodeType from core.workflow.nodes.tool.entities import ToolNodeData -from core.workflow.repositories.workflow_execution_repository import WorkflowExecutionRepository from core.workflow.workflow_type_encoder import WorkflowRuntimeTypeConverter from models import ( Account, @@ -64,10 +63,8 @@ class WorkflowResponseConverter: self, *, application_generate_entity: Union[AdvancedChatAppGenerateEntity, WorkflowAppGenerateEntity], - workflow_execution_repository: WorkflowExecutionRepository, ) -> None: self._application_generate_entity = application_generate_entity - self._workflow_execution_repository = workflow_execution_repository def workflow_start_to_stream_response( self, diff --git a/api/core/app/apps/workflow/generate_task_pipeline.py b/api/core/app/apps/workflow/generate_task_pipeline.py index ac4c7a061f..c6b326d8a4 100644 --- a/api/core/app/apps/workflow/generate_task_pipeline.py +++ b/api/core/app/apps/workflow/generate_task_pipeline.py @@ -126,7 +126,6 @@ class WorkflowAppGenerateTaskPipeline: self._workflow_response_converter = WorkflowResponseConverter( application_generate_entity=application_generate_entity, - workflow_execution_repository=workflow_execution_repository, ) self._application_generate_entity = application_generate_entity