|
@@ -182,7 +182,7 @@ class NewContentIdTask(object):
|
|
|
|
|
|
async def judge_whether_same_content_id_is_processing(self, content_id):
|
|
|
"""
|
|
|
- 同一个 content_id只需要处理一次
|
|
|
+ 同一个 content_id 只需要处理一次
|
|
|
:param content_id:
|
|
|
:return:
|
|
|
success: 4
|
|
@@ -203,7 +203,8 @@ class NewContentIdTask(object):
|
|
|
self.TASK_KIMI_FINISHED_STATUS,
|
|
|
self.TASK_SPIDER_FINISHED_STATUS,
|
|
|
self.TASK_ETL_FINISHED_STATUS,
|
|
|
- self.TASK_PROCESSING_STATUS
|
|
|
+ self.TASK_PROCESSING_STATUS,
|
|
|
+ self.TASK_PUBLISHED_STATUS
|
|
|
}:
|
|
|
return True
|
|
|
return False
|