@@ -829,13 +829,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()