newContentIdTask.py

debug
不修改成功的状态

tasks/newContentIdTask.py

@@ -71,20 +71,21 @@ class NewContentIdTask(object):
                         process_times=obj['process_times'] + 1,
                         trace_id=obj['trace_id']
                     )
-        # 将  process_times > 3 的任务的状态修改为失败
+        # 将  process_times > 3 且状态不为 4 的任务的状态修改为失败,
         update_status_sql = f"""
             UPDATE 
                 {self.article_match_video_table}
             SET 
                 content_status = %s
             WHERE 
-                process_times > %s;
+                process_times > %s and content_status != %s;
         """
         await self.mysql_client.async_insert(
             update_status_sql,
             params=(
                 self.TASK_FAIL_STATUS,
-                self.TASK_MAX_PROCESS_TIMES
+                self.TASK_MAX_PROCESS_TIMES,
+                self.TASK_PUBLISHED_STATUS
             )
         )
         # 获取  process_times <= 3 且  content_status = 0 的任务