refactor(workflow_response_converter): Remove unused workflow_execution_repository

Signed-off-by: -LAN- <laipz8200@outlook.com>
pull/22581/head
-LAN- 10 months ago
parent b1e9c086cf
commit c5e0ab5469
No known key found for this signature in database
GPG Key ID: 6BA0D108DED011FF

@ -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()

@ -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,

@ -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

Loading…
Cancel
Save