oops.

Author: erinleighh

python/activator/activator.py

@@ -878,7 +878,7 @@ def process_visit(expected_visit: FannedOutVisit):
                                           _get_local_repo().name,
                                           _get_local_cache())
                 # TODO: pipeline execution requires a clean run until DM-38041.
-                cleanups.callback(mwi.clean_local_repo, expid_set)
+                cleanups.callback(mwi.clean_local_repo)
                 # Copy calibrations for this detector/visit
                 mwi.prep_butler()
 

python/activator/middleware_interface.py

@@ -1720,15 +1720,10 @@ def _query_datasets_by_storage_class(self, butler, exposure_ids, collections, st
                                   ) for t in matching_types
         )
 
-    def clean_local_repo(self, exposure_ids: set[int]) -> None:
+    def clean_local_repo(self) -> None:
         """Remove local repo content that is only needed for a single visit.
 
         This includes raws and pipeline outputs.
-
-        Parameter
-        ---------
-        exposure_ids : `set` [`int`]
-            Identifiers of the exposures to be removed.
         """
         with lsst.utils.timer.time_this(_log, msg="clean_local_repo", level=logging.DEBUG):
             self.butler.registry.refresh()

tests/test_middleware_interface.py

@@ -1019,7 +1019,7 @@ def test_clean_local_repo(self):
         self._assert_in_collection(butler, "*", "bias", calib_data_id_2)
         self._assert_in_collection(butler, "*", "bias", calib_data_id_3)
 
-        self.interface.clean_local_repo({raw_data_id["exposure"]})
+        self.interface.clean_local_repo()
         self._assert_not_in_collection(butler, "*", "raw", raw_data_id)
         self._assert_not_in_collection(butler, "*", "src", processed_data_id)
         self._assert_not_in_collection(butler, "*", "calexp", processed_data_id)