Merge branch 'tickets/DM-43584'

Author: kfindeisen

python/activator/middleware_interface.py

@@ -64,6 +64,8 @@
 # VALIDITY-HACK: local-only calib collections break if calibs are not requested
 # in chronological order. Turn off for large development runs.
 cache_calibs = bool(int(os.environ.get("DEBUG_CACHE_CALIBS", '1')))
+# TODO: workaround for DM-40193
+cache_anything = bool(int(os.environ.get("DEBUG_CACHE_INPUTS", '1')))
 
 
 def get_central_butler(central_repo: str, instrument_class: str):
@@ -1370,6 +1372,11 @@ def clean_local_repo(self, exposure_ids: set[int]) -> None:
                     self.butler.registry.removeCollection(member)
                 self.butler.removeRuns(calib_runs, unstore=True)
 
+            # TODO: workaround for DM-40193
+            if not cache_anything:
+                self.butler.pruneDatasets(self.butler.registry.queryDatasets(...),
+                                          disassociate=True, unstore=True, purge=True)
+
 
 class _MissingDatasetError(RuntimeError):
     """An exception flagging that required datasets were not found