From 4ebc29768c43bb7d9eee732ac801ee8d7ce8124a Mon Sep 17 00:00:00 2001 From: John Spray Date: Mon, 14 Aug 2023 16:42:45 +0100 Subject: [PATCH] Add failpoint for deletion execution --- pageserver/src/deletion_queue.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pageserver/src/deletion_queue.rs b/pageserver/src/deletion_queue.rs index ef9275ac81..8bd8f4eeb3 100644 --- a/pageserver/src/deletion_queue.rs +++ b/pageserver/src/deletion_queue.rs @@ -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);