From 6884e1a6836bdde6f711a0db8e61f788e5588b7f Mon Sep 17 00:00:00 2001 From: -LAN- Date: Wed, 21 May 2025 22:31:43 +0800 Subject: [PATCH] chore: Move `workflow_response_converter` into `core/app/apps/common` Signed-off-by: -LAN- --- api/core/app/apps/advanced_chat/generate_task_pipeline.py | 2 +- api/core/app/apps/common/__init__.py | 0 api/core/app/{ => apps/common}/workflow_response_converter.py | 0 api/core/app/apps/workflow/generate_task_pipeline.py | 2 +- 4 files changed, 2 insertions(+), 2 deletions(-) create mode 100644 api/core/app/apps/common/__init__.py rename api/core/app/{ => apps/common}/workflow_response_converter.py (100%) 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 a088d19c70..e43417668d 100644 --- a/api/core/app/apps/advanced_chat/generate_task_pipeline.py +++ b/api/core/app/apps/advanced_chat/generate_task_pipeline.py @@ -10,6 +10,7 @@ from sqlalchemy.orm import Session from constants.tts_auto_play_timeout import TTS_AUTO_PLAY_TIMEOUT, TTS_AUTO_PLAY_YIELD_CPU_TIME from core.app.apps.base_app_queue_manager import AppQueueManager, PublishFrom +from core.app.apps.common.workflow_response_converter import WorkflowResponseConverter from core.app.entities.app_invoke_entities import ( AdvancedChatAppGenerateEntity, InvokeFrom, @@ -57,7 +58,6 @@ from core.app.entities.task_entities import ( ) from core.app.task_pipeline.based_generate_task_pipeline import BasedGenerateTaskPipeline from core.app.task_pipeline.message_cycle_manage import MessageCycleManage -from core.app.workflow_response_converter import WorkflowResponseConverter from core.base.tts import AppGeneratorTTSPublisher, AudioTrunk from core.model_runtime.entities.llm_entities import LLMUsage from core.model_runtime.utils.encoders import jsonable_encoder diff --git a/api/core/app/apps/common/__init__.py b/api/core/app/apps/common/__init__.py new file mode 100644 index 0000000000..e69de29bb2 diff --git a/api/core/app/workflow_response_converter.py b/api/core/app/apps/common/workflow_response_converter.py similarity index 100% rename from api/core/app/workflow_response_converter.py rename to api/core/app/apps/common/workflow_response_converter.py diff --git a/api/core/app/apps/workflow/generate_task_pipeline.py b/api/core/app/apps/workflow/generate_task_pipeline.py index 4d1ed429a2..0291f49cac 100644 --- a/api/core/app/apps/workflow/generate_task_pipeline.py +++ b/api/core/app/apps/workflow/generate_task_pipeline.py @@ -8,6 +8,7 @@ from sqlalchemy.orm import Session from constants.tts_auto_play_timeout import TTS_AUTO_PLAY_TIMEOUT, TTS_AUTO_PLAY_YIELD_CPU_TIME from core.app.apps.base_app_queue_manager import AppQueueManager +from core.app.apps.common.workflow_response_converter import WorkflowResponseConverter from core.app.entities.app_invoke_entities import ( InvokeFrom, WorkflowAppGenerateEntity, @@ -52,7 +53,6 @@ from core.app.entities.task_entities import ( WorkflowTaskState, ) from core.app.task_pipeline.based_generate_task_pipeline import BasedGenerateTaskPipeline -from core.app.workflow_response_converter import WorkflowResponseConverter from core.base.tts import AppGeneratorTTSPublisher, AudioTrunk from core.ops.ops_trace_manager import TraceQueueManager from core.workflow.entities.workflow_execution_entities import WorkflowExecution