summaryrefslogtreecommitdiff
path: root/ext/kv/remote.rs
diff options
context:
space:
mode:
Diffstat (limited to 'ext/kv/remote.rs')
-rw-r--r--ext/kv/remote.rs12
1 files changed, 9 insertions, 3 deletions
diff --git a/ext/kv/remote.rs b/ext/kv/remote.rs
index 448a87b0d..21286fd47 100644
--- a/ext/kv/remote.rs
+++ b/ext/kv/remote.rs
@@ -494,9 +494,15 @@ async fn call_remote<
// `unwrap()` never fails because `tx` is owned by the task held by `refresher`.
metadata_rx.changed().await.unwrap();
};
- let Some(sc_endpoint) = metadata.endpoints.iter().find(|x| x.consistency == "strong") else {
- return Err(type_error("No strong consistency endpoint is available for this database"));
- };
+ let Some(sc_endpoint) = metadata
+ .endpoints
+ .iter()
+ .find(|x| x.consistency == "strong")
+ else {
+ return Err(type_error(
+ "No strong consistency endpoint is available for this database",
+ ));
+ };
let full_url = format!("{}/{}", sc_endpoint.url, method);
{