长文-聚类优化

app/jobs/task_handler.py

@@ -493,5 +493,14 @@ class TaskHandler:
         await task.deal(task_name="fetch_results")
         return TaskStatus.SUCCESS
 
+    @register("extract_ad_platform_accounts_decode_result")
+    async def _extract_ad_platform_accounts_decode_result(self) -> int:
+        """提取解构任务结果"""
+        task = AdPlatformArticlesDecodeTask(
+            pool=self.db_client, log_service=self.log_client
+        )
+        await task.deal(task_name="extract")
+        return TaskStatus.SUCCESS
+
 
 __all__ = ["TaskHandler"]