diff --git a/crates/pool/src/server/local.rs b/crates/pool/src/server/local.rs index 0733f9a78..f7413b2d6 100644 --- a/crates/pool/src/server/local.rs +++ b/crates/pool/src/server/local.rs @@ -106,9 +106,14 @@ impl LocalPoolHandle { response: send, }) .await - .map_err(|_| anyhow::anyhow!("LocalPoolServer closed"))?; - recv.await - .map_err(|_| anyhow::anyhow!("LocalPoolServer closed"))? + .map_err(|_| { + error!("LocalPoolServer sender closed"); + PoolError::UnexpectedResponse + })?; + recv.await.map_err(|_| { + error!("LocalPoolServer receiver closed"); + PoolError::UnexpectedResponse + })? } }