diff --git a/pageserver/src/page_service.rs b/pageserver/src/page_service.rs index 4d587a6e6c..2b9bc2d31f 100644 --- a/pageserver/src/page_service.rs +++ b/pageserver/src/page_service.rs @@ -287,8 +287,8 @@ impl<'a> Read for CopyInReader<'a> { } // Shutting down - // TODO is this fine? - Ok(0) + let msg = "Importer thread was shut down"; + Err(io::Error::new(io::ErrorKind::Other, msg)) } }