From 16d6d708f6d1ca51fcbe4c3405c8bdc4a12d96fc Mon Sep 17 00:00:00 2001 From: "Richard Kuo (Danswer)" Date: Tue, 11 Feb 2025 09:15:39 -0800 Subject: [PATCH] update logging --- backend/onyx/background/celery/apps/beat.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/backend/onyx/background/celery/apps/beat.py b/backend/onyx/background/celery/apps/beat.py index 45fe040fc6b..ab2d522d1a6 100644 --- a/backend/onyx/background/celery/apps/beat.py +++ b/backend/onyx/background/celery/apps/beat.py @@ -30,10 +30,9 @@ class DynamicTenantScheduler(PersistentScheduler): """This scheduler is useful because we can dynamically adjust task generation rates through it.""" - RELOAD_INTERVAL = 120 + RELOAD_INTERVAL = 60 def __init__(self, *args: Any, **kwargs: Any) -> None: - task_logger.info("Initializing DynamicTenantScheduler") super().__init__(*args, **kwargs) self.last_beat_multiplier = CLOUD_BEAT_MULTIPLIER_DEFAULT @@ -46,7 +45,9 @@ class DynamicTenantScheduler(PersistentScheduler): # Let the parent class handle store initialization self.setup_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: super().setup_schedule()