File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
rust/garbage_collector/src Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -293,6 +293,8 @@ impl Handler<GarbageCollectMessage> for GarbageCollector {
293293 collections_to_gc. len( )
294294 ) ;
295295
296+ let mut sysdb = self . sysdb_client . clone ( ) ;
297+
296298 let mut jobs = FuturesUnordered :: new ( ) ;
297299
298300 let mut num_skipped_jobs = 0 ;
@@ -371,6 +373,13 @@ impl Handler<GarbageCollectMessage> for GarbageCollector {
371373 & [ opentelemetry:: KeyValue :: new ( "status" , "failure" ) ] ,
372374 ) ;
373375
376+ if let Err ( err) = sysdb
377+ . finish_database_deletion ( absolute_cutoff_time. into ( ) )
378+ . await
379+ {
380+ tracing:: error!( "Call to FinishDatabaseDeletion failed: {:?}" , err) ;
381+ }
382+
374383 // Schedule next run
375384 ctx. scheduler . schedule (
376385 GarbageCollectMessage {
You can’t perform that action at this time.
0 commit comments