highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-09-19 12:03:54 +02:00
Code Issues Packages Projects Releases Wiki Activity

log processed tenant count (#4139)

Browse Source 
Co-authored-by: Richard Kuo (Danswer) <rkuo@onyx.app>
This commit is contained in:
rkuo-danswer
2025-02-26 17:26:48 -08:00
committed by GitHub
parent f2d74ce540
commit 11e7e1c4d6
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/onyx/background/celery/tasks/shared/tasks.py
View File

@@ -298,6 +298,7 @@ def cloud_beat_task_generator(
last_lock_time = time.monotonic() last_lock_time = time.monotonic()
tenant_ids: list[str] = [] tenant_ids: list[str] = []
num_processed_tenants = 0
try: try:
tenant_ids = get_all_tenant_ids() tenant_ids = get_all_tenant_ids()
@@ -325,6 +326,8 @@ def cloud_beat_task_generator(
expires=expires, expires=expires,
ignore_result=True, ignore_result=True,
) )
num_processed_tenants += 1
except SoftTimeLimitExceeded: except SoftTimeLimitExceeded:
task_logger.info( task_logger.info(
"Soft time limit exceeded, task is being terminated gracefully." "Soft time limit exceeded, task is being terminated gracefully."
@@ -344,6 +347,7 @@ def cloud_beat_task_generator(
task_logger.info( task_logger.info(
f"cloud_beat_task_generator finished: " f"cloud_beat_task_generator finished: "
f"task={task_name} " f"task={task_name} "
f"num_processed_tenants={num_processed_tenants} "
f"num_tenants={len(tenant_ids)} " f"num_tenants={len(tenant_ids)} "
f"elapsed={time_elapsed:.2f}" f"elapsed={time_elapsed:.2f}"
) )