卡片解构

app/domains/monitor_tasks/auto_reply_cards_monitor/_mapper.py

@@ -150,7 +150,8 @@ class AutoReplyCardsMonitorMapper(AutoReplyCardsMonitorConst):
     # 获取带解析的任务
     async def get_extract_tasks(self):
         query = """
-            SELECT task_id, result FROM cooperate_accounts_task WHERE extract_status = %s AND task_status = %s;
+            SELECT task_id, result FROM cooperate_accounts_task WHERE extract_status = %s AND task_status = %s
+            LIMIT 200;
         """
         return await self.pool.async_fetch(
             query=query, params=(self.INIT_STATUS, self.SUCCESS_STATUS)