Inner Decode Tasks

app/domains/llm_tasks/aigc_decode_task/_mapper.py

@@ -6,7 +6,7 @@ from ._const import DecodeTaskConst
 
 
 class ArticlesDecodeTaskMapper(DecodeTaskConst):
-    DECODE_TASK_QUEUE = "long_articles_decode_task_detail"
+    DECODE_TASK_QUEUE = "long_articles_decode_tasks"
     INNER_DECODE_CREATE_STATE = "long_articles_inner_decode_create_state"
 
     def __init__(self, pool: DatabaseManager):
@@ -191,7 +191,8 @@ class InnerArticlesDecodeTaskMapper(ArticlesDecodeTaskMapper):
             date_string = self.InnerDecodeCreate.DEFAULT_GOOD_READ_DATE
         query = """
             SELECT title, source_id, wx_sn, cover_img_url FROM long_articles_good_read_article WHERE dt = %s
-            ORDER by max_read_rate DESC;
+            ORDER by max_read_rate DESC
+            ;
         """
         return await self.pool.async_fetch(query=query, params=(date_string,))
 

app/domains/llm_tasks/aigc_decode_task/create_decode_tasks.py

@@ -381,7 +381,7 @@ class CreateInnerArticlesDecodeTask(DecodeTaskConst):
 
         decode_types = [
             self.TaskType.SOURCE_IMAGES_TEXT,
-            # self.TaskType.PUBLISH_TITLE_COVER
+            self.TaskType.PUBLISH_TITLE_COVER
         ]
         task_list = [
             {"article": article, "task_type": task_type}