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

update logging

Browse Source
This commit is contained in:
Richard Kuo (Danswer)
2025-02-11 09:15:39 -08:00
parent 9740ed32b5
commit 16d6d708f6
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
backend/onyx/background/celery/apps/beat.py
View File

@@ -30,10 +30,9 @@ class DynamicTenantScheduler(PersistentScheduler):
"""This scheduler is useful because we can dynamically adjust task generation rates """This scheduler is useful because we can dynamically adjust task generation rates
through it.""" through it."""
RELOAD_INTERVAL = 120 RELOAD_INTERVAL = 60
def __init__(self, *args: Any, **kwargs: Any) -> None: def __init__(self, *args: Any, **kwargs: Any) -> None:
task_logger.info("Initializing DynamicTenantScheduler")
super().__init__(*args, **kwargs) super().__init__(*args, **kwargs)
self.last_beat_multiplier = CLOUD_BEAT_MULTIPLIER_DEFAULT self.last_beat_multiplier = CLOUD_BEAT_MULTIPLIER_DEFAULT
@@ -46,7 +45,9 @@ class DynamicTenantScheduler(PersistentScheduler):
# Let the parent class handle store initialization # Let the parent class handle store initialization
self.setup_schedule() self.setup_schedule()
self._try_updating_schedule() self._try_updating_schedule()
task_logger.info(f"Setting reload interval to {self._reload_interval}") task_logger.info(
f"DynamicTenantScheduler initialized: reload_interval={self._reload_interval}"
)
def setup_schedule(self) -> None: def setup_schedule(self) -> None:
super().setup_schedule() super().setup_schedule()