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 {
293
293
collections_to_gc. len( )
294
294
) ;
295
295
296
+ let mut sysdb = self . sysdb_client . clone ( ) ;
297
+
296
298
let mut jobs = FuturesUnordered :: new ( ) ;
297
299
298
300
let mut num_skipped_jobs = 0 ;
@@ -371,6 +373,13 @@ impl Handler<GarbageCollectMessage> for GarbageCollector {
371
373
& [ opentelemetry:: KeyValue :: new ( "status" , "failure" ) ] ,
372
374
) ;
373
375
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
+
374
383
// Schedule next run
375
384
ctx. scheduler . schedule (
376
385
GarbageCollectMessage {
You can’t perform that action at this time.
0 commit comments