commit by Kalman.CHENG ☆

dsLightRag/Routes/TeachingModel/tasks/BackgroundTasks.py

@@ -16,12 +16,12 @@ logger.addHandler(handler)
 
 # 后台任务，监控是否有新的未训练的文档进行训练
 async def train_document_task():
-    print(datetime.datetime.now(), "线程5秒后开始运行【监控是否有需要处理的文档】")
+    print(datetime.datetime.now(), "5秒后开始运行【监控是否有需要处理的文档】")
     await asyncio.sleep(5)  # 使用 asyncio.sleep 而不是 time.sleep
     # 这里放置你的线程逻辑
     while True:
-        print("测试定时任务运行")
         handle_flag = False
+        print(f"定时任务正常运行，训练开启状态：{handle_flag};")
         if handle_flag:
             # 这里可以放置你的线程要执行的代码
             logging.info("开始查询是否有待处理文档：")
@@ -98,5 +98,4 @@ async def train_document_task():
                         update_theme_sql: str = f"UPDATE t_ai_teaching_model_theme SET search_flag = 0, train_flag = 0 WHERE id = {theme['id']}"
                         await execute_sql(update_theme_sql, ())
         # 添加适当的等待时间，避免频繁查询
-        await asyncio.sleep(20) # 开发阶段每20秒一次
-        # await asyncio.sleep(600)  # 每十分钟查询一次
+        await asyncio.sleep(120)  # 每二分钟查询一次