账号质量分析

applications/tasks/llm_tasks/candidate_account_process.py

@@ -202,7 +202,7 @@ class CandidateAccountQualityScoreRecognizer(CandidateAccountProcessConst):
             select count(1) as new_mining_account from article_meta_accounts
             where trace_id = %s;
         """
-        return await self.pool.async_fetch(query, (self.trace_id,))
+        return await self.pool.async_fetch(query=query, params=(self.trace_id,))
 
     async def deal(self):
         task_list = await self.get_task_list()

applications/tasks/llm_tasks/process_title.py

@@ -441,7 +441,7 @@ class ArticlePoolCategoryGeneration(TitleProcess):
             limit = self.PROCESS_NUM
 
         task_list = await self.get_task_list(limit=limit)
-        print(task_list)
+        print(type(task_list))
         await self.aliyun_log.log(
             contents={
                 "task": "ArticlePoolCategoryGeneration",
@@ -450,6 +450,7 @@ class ArticlePoolCategoryGeneration(TitleProcess):
                 "message": f"总共获取{len(task_list)}条文章",
             }
         )
+        print(task_list)
         task_batch_list = yield_batch(data=task_list, batch_size=self.BATCH_SIZE)
         batch_index = 0
         for task_batch in task_batch_list: