Skip to content

Commit 4573e07

Browse files
committed
Make raw deletion more thorough.
1 parent 21c0672 commit 4573e07

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

python/activator/middleware_interface.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1747,16 +1747,16 @@ def clean_local_repo(self, exposure_ids: set[int]) -> None:
17471747
"""
17481748
with lsst.utils.timer.time_this(_log, msg="clean_local_repo", level=logging.DEBUG):
17491749
self.butler.registry.refresh()
1750-
if exposure_ids:
1751-
raws = self.butler.query_datasets(
1752-
'raw',
1753-
collections=self.instrument.makeDefaultRawIngestRunName(),
1754-
where=f"exposure in ({', '.join(str(x) for x in exposure_ids)})",
1755-
explain=False, # Raws might not have been ingested.
1756-
instrument=self.visit.instrument,
1757-
detector=self.visit.detector,
1758-
)
1759-
self.butler.pruneDatasets(raws, disassociate=True, unstore=True, purge=True)
1750+
# Clean out raws
1751+
raws = self.butler.query_datasets(
1752+
'raw',
1753+
collections=self.instrument.makeDefaultRawIngestRunName(),
1754+
explain=False, # Raws might not have been ingested.
1755+
instrument=self.visit.instrument,
1756+
detector=self.visit.detector,
1757+
)
1758+
self.butler.pruneDatasets(raws, disassociate=True, unstore=True, purge=True)
1759+
17601760
# Outputs are all in their own runs, so just drop them.
17611761
preload_run = runs.get_preload_run(self.instrument, self._deployment, self._day_obs)
17621762
_remove_run_completely(self.butler, preload_run)

0 commit comments

Comments
 (0)