Add failpoint for deletion execution

This commit is contained in:
John Spray
2023-08-14 16:42:45 +01:00
parent bae62916dc
commit 4ebc29768c

View File

@@ -191,6 +191,10 @@ pub struct BackendQueueWorker {
impl BackendQueueWorker {
async fn maybe_execute(&mut self) {
fail::fail_point!("deletion-queue-before-execute", |_| {
return;
});
match self.remote_storage.delete_objects(&self.accumulator).await {
Ok(()) => {
DELETION_QUEUE_EXECUTED.inc_by(self.accumulator.len() as u64);