架构优化

app/ab_test/get_cover.py

@@ -1,4 +1,4 @@
-from app.infra.utils.response import Response
+from app.infra.shared.response import Response
 from app.infra.utils import fetch_channel_info
 from app.infra.utils import fetch_aigc_cover
 from app.infra.utils import fetch_long_video_cover

app/api/service/task_scheduler.py

@@ -5,7 +5,7 @@ from datetime import datetime, timedelta
 from typing import Optional, Dict, Any, List
 
 from app.infra.external import feishu_robot
-from app.infra.utils import task_schedule_response
+from app.infra.shared import task_schedule_response
 from app.jobs.task_handler import TaskHandler
 from app.jobs.task_config import (
     TaskStatus,

app/infra/shared/__init__.py

@@ -1,2 +1,8 @@
 from .async_tasks import run_tasks_with_asyncio_task_group
 from .http_client import AsyncHttpClient
+
+# server response
+from app.infra.shared.response import TaskScheduleResponse
+
+# async tasks
+task_schedule_response = TaskScheduleResponse()

app/infra/utils/__init__.py

@@ -1,9 +1,3 @@
 from .get_cover import fetch_channel_info
 from .get_cover import fetch_aigc_cover
 from .get_cover import fetch_long_video_cover
-
-# server response
-from .response import TaskScheduleResponse
-
-# async tasks
-task_schedule_response = TaskScheduleResponse()