|
@@ -6,6 +6,8 @@ import asyncio
|
|
|
from applications.static.config import db_article
|
|
|
from applications.schedule import search_videos
|
|
|
from applications.functions.log import logging
|
|
|
+from applications.static.config import mysql_coroutines
|
|
|
+
|
|
|
|
|
|
|
|
|
class ProcessDeal2(object):
|
|
@@ -30,7 +32,7 @@ class ProcessDeal2(object):
|
|
|
WHERE content_status = 0 and process_times <= 5
|
|
|
ORDER BY request_time_stamp
|
|
|
ASC
|
|
|
- LIMIT 40;
|
|
|
+ LIMIT {mysql_coroutines};
|
|
|
"""
|
|
|
task_list = await self.mysql_client.async_select(sql=select_sql)
|
|
|
task_obj_list = [
|