AI/dify
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/langgenius/dify.git synced 2025-08-14 03:35:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: change TRACE_QUEUE_MANAGER_INTERVAL default value (#5698)

Browse Source 
Co-authored-by: takatost <takatost@gmail.com>
This commit is contained in:
Joe 2024-06-28 17:34:58 +08:00 committed by GitHub
parent 73ce945d40
commit dd5f3873da
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/app.py
View File

@ -26,7 +26,6 @@ from werkzeug.exceptions import Unauthorized
from commands import register_commands from commands import register_commands
# DO NOT REMOVE BELOW # DO NOT REMOVE BELOW
from events import event_handlers
from extensions import ( from extensions import (
ext_celery, ext_celery,
ext_code_based_extension, ext_code_based_extension,
@ -43,7 +42,6 @@ from extensions import (
from extensions.ext_database import db from extensions.ext_database import db
from extensions.ext_login import login_manager from extensions.ext_login import login_manager
from libs.passport import PassportService from libs.passport import PassportService
from models import account, dataset, model, source, task, tool, tools, web
from services.account_service import AccountService from services.account_service import AccountService
# DO NOT REMOVE ABOVE # DO NOT REMOVE ABOVE

2
api/core/ops/ops_trace_manager.py
View File

@ -660,7 +660,7 @@ class TraceTask:
trace_manager_timer = None trace_manager_timer = None
trace_manager_queue = queue.Queue() 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)) trace_manager_batch_size = int(os.getenv("TRACE_QUEUE_MANAGER_BATCH_SIZE", 100))