From c3483f75aefdca551a28f4b08450029e2147e99c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=AF=9B=E9=B9=8F?= <729164035@qq.com> Date: Fri, 5 Dec 2025 21:12:06 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- MangoServer/src/auto_test/auto_system/apps.py | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/MangoServer/src/auto_test/auto_system/apps.py b/MangoServer/src/auto_test/auto_system/apps.py index 132928bc..660cc713 100644 --- a/MangoServer/src/auto_test/auto_system/apps.py +++ b/MangoServer/src/auto_test/auto_system/apps.py @@ -37,7 +37,7 @@ class AutoSystemConfig(AppConfig): self.populate_time_tasks() self.run_tests() self.init_ass() - + # 设置定时任务调度器 self.setup_scheduler() @@ -153,8 +153,6 @@ class AutoSystemConfig(AppConfig): self.system_task.join() except AttributeError: pass - # 停止全局调度器 - self.stop_scheduler() def init_ass(self): try: @@ -189,7 +187,7 @@ class AutoSystemConfig(AppConfig): try: # 创建调度器实例 self.scheduler = BackgroundScheduler() - + # 添加定时任务 self.scheduler.add_job( self.set_case_status, @@ -197,10 +195,10 @@ class AutoSystemConfig(AppConfig): minutes=5, id='set_case_status' ) - + # 启动调度器 self.scheduler.start() - + # 注册退出时停止调度器 atexit.register(self.stop_scheduler) except Exception as e: @@ -217,14 +215,13 @@ class AutoSystemConfig(AppConfig): except Exception as e: log.system.error(f'停止调度器异常: {e}') - def set_case_status(self): from django.db import transaction try: # 确保开始时连接是干净的 close_old_connections() - + from src.auto_test.auto_ui.models import UiCase, UiCaseStepsDetailed, PageSteps from src.auto_test.auto_pytest.models import PytestCase from src.auto_test.auto_api.models import ApiInfo, ApiCase, ApiCaseDetailed @@ -246,9 +243,9 @@ class AutoSystemConfig(AppConfig): status=TaskEnum.PROCEED.value, update_time__lt=ten_minutes_ago ).update(status=TaskEnum.FAIL.value) - + # 确保事务提交 transaction.commit() finally: # 确保结束时连接被关闭 - close_old_connections() \ No newline at end of file + close_old_connections()