|
|
@@ -272,6 +272,13 @@ class NewContentIdTask(object):
|
|
|
info="多个进程抢占同一个任务的执行状态锁，抢占失败，return"
|
|
|
)
|
|
|
return
|
|
|
+ logging(
|
|
|
+ code="8023",
|
|
|
+ function="kimi_task",
|
|
|
+ trace_id=trace_id,
|
|
|
+ info="从root_content_id获取结果",
|
|
|
+ data=params
|
|
|
+ )
|
|
|
return kimi_result
|
|
|
|
|
|
# 处理content_id
|
|
|
@@ -368,6 +375,13 @@ class NewContentIdTask(object):
|
|
|
)
|
|
|
if affected_rows == 0:
|
|
|
return
|
|
|
+ logging(
|
|
|
+ code="8024",
|
|
|
+ function="spider_task",
|
|
|
+ trace_id=trace_id,
|
|
|
+ info="从root_content_id获取结果",
|
|
|
+ data=params
|
|
|
+ )
|
|
|
return True
|
|
|
|
|
|
download_video_exist_flag = await whether_downloaded_videos_exists(
|
