Add debug logs for caching behavior

lsst · Mar 15, 2024 · 39b2f74 · 39b2f74
1 parent 28c18cb
commit 39b2f74
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/python/lsst/pipe/base/caching_limited_butler.py b/python/lsst/pipe/base/caching_limited_butler.py
@@ -103,6 +103,7 @@ def get(
         if cached := self._cache.get(ref.datasetType.name):
             dataset_id, handle = cached
             if dataset_id == ref.id:  # if we do, check it's the right object
+                self.log.debug("Returning cached dataset %s", ref)
                 return handle.get(parameters=parameters, storageClass=storageClass)
 
         obj = self._wrapped.get(ref, parameters=parameters, storageClass=storageClass)
@@ -117,6 +118,7 @@ def get(
                     copy=ref.datasetType.name not in self._no_copy_on_cache,
                 ),
             )
+            self.log.debug("Cached dataset %s", ref)
         return obj
 
     def getDeferred(
@@ -161,6 +163,7 @@ def put(self, obj: Any, ref: DatasetRef) -> DatasetRef:
                     copy=ref.datasetType.name not in self._no_copy_on_cache,
                 ),
             )
+            self.log.debug("Cached dataset %s on put", ref)
         return self._wrapped.put(obj, ref)
 
     def pruneDatasets(