@@ -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