架构优化

app/api/service/task_scheduler.py

@@ -33,12 +33,12 @@ class TaskScheduler(TaskHandler):
     """
 
     def __init__(
-            self,
-            data: dict,
-            log_service: LogService,
-            db_client: DatabaseManager,
-            trace_id: str,
-            config: GlobalConfigSettings
+        self,
+        data: dict,
+        log_service: LogService,
+        db_client: DatabaseManager,
+        trace_id: str,
+        config: GlobalConfigSettings,
     ):
         super().__init__(data, log_service, db_client, trace_id, config)
         self.table = TaskUtils.validate_table_name(TaskConstants.TASK_TABLE)

app/domains/cold_start_tasks/article_pool_cold_start.py

@@ -283,6 +283,7 @@ class ArticlePoolColdStart(ArticlePoolColdStartStrategy, ArticlePoolFilterStrate
                         "function": "deal",
                         "traceback": traceback.format_exc(),
                     },
+                    mention=False,
                 )
 
         if self.cold_start_records:

app/infra/shared/__init__.py

@@ -5,4 +5,4 @@ from .http_client import AsyncHttpClient
 from app.infra.shared.response import TaskScheduleResponse
 
 # async tasks
-task_schedule_response = TaskScheduleResponse()
+task_schedule_response = TaskScheduleResponse()