add log to task

tasks/new_contentId_task.py

@@ -4,7 +4,6 @@
 import json
 import time
 import asyncio
-import traceback
 
 from typing import List, Dict
 
@@ -336,8 +335,6 @@ class NewContentIdTask(object):
                 return kimi_result
             except Exception as e:
                 # kimi 任务处理失败
-                error = traceback.format_exc()
-                print(error)
                 update_kimi_sql = f"""
                         UPDATE {self.article_text_table}
                         SET
@@ -765,13 +762,13 @@ class NewContentIdTask(object):
         :return:
         """
         # 处理未托管的任务
-        # await self.roll_back_unfinished_tasks(publish_flag=NewContentIdTaskConst.NEED_PUBLISH)
+        await self.roll_back_unfinished_tasks(publish_flag=NewContentIdTaskConst.NEED_PUBLISH)
 
         # 处理托管任务
-        # await self.roll_back_unfinished_tasks(publish_flag=NewContentIdTaskConst.DO_NOT_NEED_PUBLISH)
+        await self.roll_back_unfinished_tasks(publish_flag=NewContentIdTaskConst.DO_NOT_NEED_PUBLISH)
 
         # 将处理次数大于3次且未成功的任务置为失败
-        # await self.set_tasks_status_fail()
+        await self.set_tasks_status_fail()
 
         # 获取task_list
         task_list = await self.get_tasks()