|
@@ -251,7 +251,6 @@ class historyContentIdTask(object):
|
|
|
else:
|
|
else:
|
|
|
return False
|
|
return False
|
|
|
|
|
|
|
|
-
|
|
|
|
|
async def process_task(self, params):
|
|
async def process_task(self, params):
|
|
|
"""
|
|
"""
|
|
|
异步执行
|
|
异步执行
|
|
@@ -267,7 +266,7 @@ class historyContentIdTask(object):
|
|
|
# 修改状态为执行状态
|
|
# 修改状态为执行状态
|
|
|
affected_rows = await self.update_content_status(
|
|
affected_rows = await self.update_content_status(
|
|
|
trace_id=trace_id,
|
|
trace_id=trace_id,
|
|
|
- new_content_status=self.TASK_PROCESSING_STATUS,
|
|
|
|
|
|
|
+ new_content_status=self.EXIT_STATUS,
|
|
|
ori_content_status=self.TASK_INIT_STATUS
|
|
ori_content_status=self.TASK_INIT_STATUS
|
|
|
)
|
|
)
|
|
|
if affected_rows == 0:
|
|
if affected_rows == 0:
|
