|
|
@@ -743,16 +743,18 @@ class NewContentIdTask(object):
|
|
|
info="kimi处理次数达到上限， 放弃处理",
|
|
|
trace_id=trace_id
|
|
|
)
|
|
|
+ # 将相同的content_id && content_status = 0的状态修改为kimi 失败状态
|
|
|
update_sql = f"""
|
|
|
UPDATE {self.article_match_video_table}
|
|
|
- SER content_status = %s
|
|
|
- WHERE content_id = %s;
|
|
|
+ SET content_status = %s
|
|
|
+ WHERE content_id = %s and content_status = %s;
|
|
|
"""
|
|
|
affected_rows = await self.mysql_client.async_insert(
|
|
|
sql=update_sql,
|
|
|
params=(
|
|
|
self.KIMI_ILLEGAL_STATUS,
|
|
|
- content_id
|
|
|
+ content_id,
|
|
|
+ self.TASK_INIT_STATUS
|
|
|
)
|
|
|
)
|
|
|
bot(
|
