diff --git a/scywr/src/session.rs b/scywr/src/session.rs index be9309c..c319e6e 100644 --- a/scywr/src/session.rs +++ b/scywr/src/session.rs @@ -27,7 +27,7 @@ impl From for Error { pub async fn create_session_no_ks(scyconf: &ScyllaIngestConfig) -> Result, Error> { let profile = ExecutionProfileBuilder::default() - .consistency(Consistency::Any) + .consistency(Consistency::One) .build() .into_handle(); let port_range: RangeInclusive = 32000u16..=36000u16;