Skip to content

Commit

Permalink
rust 1.73
Browse files Browse the repository at this point in the history
  • Loading branch information
conorbros committed Oct 6, 2023
1 parent 4bc14c8 commit 5f6bc0f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 5 deletions.
2 changes: 1 addition & 1 deletion rust-toolchain.toml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
[toolchain]
channel = "1.72"
channel = "1.73"
components = [ "rustfmt", "clippy" ]
targets = [ "aarch64-unknown-linux-gnu" ]
12 changes: 8 additions & 4 deletions shotover/src/transforms/cassandra/sink_cluster/rewrite.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ use cql3_parser::common::{
use cql3_parser::select::{Select, SelectElement};
use futures::future::try_join_all;
use itertools::Itertools;
use std::fmt::Write;
use std::net::{IpAddr, Ipv4Addr};
use uuid::Uuid;
use version_compare::Cmp;
Expand Down Expand Up @@ -307,10 +308,13 @@ impl MessageRewriter {
})
.collect();
if !prepared_results.windows(2).all(|w| w[0] == w[1]) {
let err_str = prepared_results
.iter()
.map(|p| format!("\n{:?}", p))
.collect::<String>();
let err_str =
prepared_results
.iter()
.fold(String::new(), |mut output, b| {
let _ = write!(output, "\n{b:?}");
output
});

tracing::error!(
"Nodes did not return the same response to PREPARE statement {err_str}"
Expand Down

0 comments on commit 5f6bc0f

Please sign in to comment.