|
@@ -97,6 +97,7 @@ class NewContentIdTask(object):
|
|
|
WHERE
|
|
|
content_status = {self.TASK_INIT_STATUS}
|
|
|
and process_times <= {self.TASK_MAX_PROCESS_TIMES}
|
|
|
+ ORDER BY flow_pool_level, request_timestamp
|
|
|
LIMIT {self.spider_coroutines};
|
|
|
"""
|
|
|
tasks = await self.mysql_client.async_select(select_sql)
|