diff --git a/src/cmap/conn.rs b/src/cmap/conn.rs index 681824471..85b9ade9d 100644 --- a/src/cmap/conn.rs +++ b/src/cmap/conn.rs @@ -327,8 +327,8 @@ impl PinnedConnectionHandle { } } - /// Retrieve the pinned connection. Will fail if the connection has been unpinned or is still in - /// use. + /// Retrieve the pinned connection. Will fail if the connection has been unpinned or is still + /// in use. pub(crate) async fn take_connection(&self) -> Result { use tokio::sync::mpsc::error::TryRecvError; let mut receiver = self.receiver.lock().await; diff --git a/src/test/csfle.rs b/src/test/csfle.rs index eb2fd3f1a..9a4df1841 100644 --- a/src/test/csfle.rs +++ b/src/test/csfle.rs @@ -3498,6 +3498,11 @@ async fn range_explicit_encryption_defaults() -> Result<()> { // using openssl causes errors after configuring a network failpoint #[cfg(not(feature = "openssl-tls"))] async fn kms_retry() { + if *super::SERVERLESS { + log_uncaptured("skipping kms_retry on serverless"); + return; + } + use reqwest::{Certificate, Client as HttpClient}; let endpoint = "127.0.0.1:9003";