From dd5f3873da2975c2fc81a7da8604665fa3627757 Mon Sep 17 00:00:00 2001 From: Joe <79627742+ZhouhaoJiang@users.noreply.github.com> Date: Fri, 28 Jun 2024 17:34:58 +0800 Subject: [PATCH] feat: change TRACE_QUEUE_MANAGER_INTERVAL default value (#5698) Co-authored-by: takatost --- api/app.py | 2 -- api/core/ops/ops_trace_manager.py | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/api/app.py b/api/app.py index 2c9b59706b..2ea7c6d235 100644 --- a/api/app.py +++ b/api/app.py @@ -26,7 +26,6 @@ from werkzeug.exceptions import Unauthorized from commands import register_commands # DO NOT REMOVE BELOW -from events import event_handlers from extensions import ( ext_celery, ext_code_based_extension, @@ -43,7 +42,6 @@ from extensions import ( from extensions.ext_database import db from extensions.ext_login import login_manager from libs.passport import PassportService -from models import account, dataset, model, source, task, tool, tools, web from services.account_service import AccountService # DO NOT REMOVE ABOVE diff --git a/api/core/ops/ops_trace_manager.py b/api/core/ops/ops_trace_manager.py index 2ce12f28d1..fbdc12331e 100644 --- a/api/core/ops/ops_trace_manager.py +++ b/api/core/ops/ops_trace_manager.py @@ -660,7 +660,7 @@ class TraceTask: trace_manager_timer = None trace_manager_queue = queue.Queue() -trace_manager_interval = int(os.getenv("TRACE_QUEUE_MANAGER_INTERVAL", 1)) +trace_manager_interval = int(os.getenv("TRACE_QUEUE_MANAGER_INTERVAL", 5)) trace_manager_batch_size = int(os.getenv("TRACE_QUEUE_MANAGER_BATCH_SIZE", 100))