From e659fdcf9c942124ced41898c6ec71051b43874e Mon Sep 17 00:00:00 2001 From: Zach Barnett Date: Sat, 22 Feb 2025 16:53:58 -0600 Subject: [PATCH] add logging to CachingRegistry --- sdk/python/feast/infra/registry/caching_registry.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sdk/python/feast/infra/registry/caching_registry.py b/sdk/python/feast/infra/registry/caching_registry.py index 042eee06ab7..5e8c8126bd1 100644 --- a/sdk/python/feast/infra/registry/caching_registry.py +++ b/sdk/python/feast/infra/registry/caching_registry.py @@ -37,6 +37,7 @@ def __init__(self, project: str, cache_ttl_seconds: int, cache_mode: str): ) self.cached_registry_proto = self.proto() self.cached_registry_proto_created = _utc_now() + logger.info(f"Registry initialized with cache mode: {cache_mode}") if cache_mode == "thread": self._start_thread_async_refresh(cache_ttl_seconds) atexit.register(self._exit_handler) @@ -456,6 +457,7 @@ def _refresh_cached_registry_if_necessary(self): self.refresh() def _start_thread_async_refresh(self, cache_ttl_seconds): + logger.info(f"Starting registry cache refresh thread with TTL {cache_ttl_seconds}") self.refresh() if cache_ttl_seconds <= 0: return @@ -464,6 +466,8 @@ def _start_thread_async_refresh(self, cache_ttl_seconds): ) self.registry_refresh_thread.daemon = True self.registry_refresh_thread.start() + logger.info("Registry cache refresh thread started") def _exit_handler(self): + logger.info("Exiting, cancelling registry cache refresh thread") self.registry_refresh_thread.cancel()