只针对level1的通过裂变率重拍

applications/match_algorithm/rank.py

@@ -71,7 +71,7 @@ async def get_content_oss_fission_dict(db_client, config, content_id) -> dict[st
         WHERE content_id = '{content_id}' and dt >= '{two_days_ago_dt}'
         ORDER BY dt DESC;
     """
-    result = await db_client.select(sql)
+    result = await db_client.async_select(sql)
     fission_info_dict = {}
     if result:
         for item in result:
@@ -110,7 +110,7 @@ async def get_title_oss_fission_dict(db_client, config, content_id) -> dict[str:
         AND dt >= {two_days_ago_dt}
         ORDER BY dt DESC;
     """
-    result = await db_client.select(sql)
+    result = await db_client.async_select(sql)
     fission_info_dict = {}
     if result:
         for item in result:

tasks/history_task.py

@@ -9,7 +9,7 @@ from applications.config import Config
 from applications.log import logging
 from applications.functions.pqFunctions import publish_to_pq, get_pq_video_detail
 from applications.functions.common import shuffle_list
-from applications.match_algorithm.rank import get_content_oss_fission_dict
+from applications.match_algorithm.rank import get_title_oss_fission_dict
 
 
 class historyContentIdTask(object):
@@ -165,7 +165,7 @@ class historyContentIdTask(object):
                 video_list = []
             case "autoArticlePoolLevel1":
                 # 头条内容，使用重排后结果
-                fission_dict = await get_content_oss_fission_dict(
+                fission_dict = await get_title_oss_fission_dict(
                     db_client=self.mysql_client,
                     config=self.config,
                     content_id=content_id