diff --git a/pageserver/src/walredo.rs b/pageserver/src/walredo.rs index 9ac1ccb526..d09c727c45 100644 --- a/pageserver/src/walredo.rs +++ b/pageserver/src/walredo.rs @@ -178,7 +178,7 @@ impl WalRedoManagerInternal { // Loop forever, handling requests as they come. loop { - let request = self.request_rx.recv().unwrap(); + let request = self.request_rx.recv().expect("WAL redo request channel was closed"); let result = runtime.block_on(self.handle_apply_request(&process, &request)); let result_ok = result.is_ok();