注册-re-extract-task

app/jobs/task_handler.py

@@ -433,6 +433,15 @@ class TaskHandler:
         await task.deal(task_name="extract_task")
         return TaskStatus.SUCCESS
 
+    @register("re_extract")
+    async def _re_extract_handler(self) -> int:
+        """重新提取封面下载失败的记录"""
+        task = AutoReplyCardsMonitor(
+            pool=self.db_client, log_service=self.log_client, config=self.config
+        )
+        await task.deal(task_name="re_extract_task")
+        return TaskStatus.SUCCESS
+
     # ==================== 其他任务 ====================
 
     @register("mini_program_detail_process")