|
@@ -56,7 +56,7 @@ class NewContentIdTask(object):
|
|
|
t1.content_status = {NewContentIdTaskConst.TASK_INIT_STATUS}
|
|
|
AND t1.process_times <= {NewContentIdTaskConst.TASK_MAX_PROCESS_TIMES}
|
|
|
AND COALESCE(t2.cnt, 0) < {NewContentIdTaskConst.MIN_MATCH_VIDEO_NUM}
|
|
|
- ORDER BY flow_pool_level, request_timestamp
|
|
|
+ ORDER BY flow_pool_level, request_timestamp DESC
|
|
|
LIMIT {self.spider_coroutines};
|
|
|
"""
|
|
|
tasks = await self.long_articles_client.async_select(select_sql)
|