From 1428af660d6851e6f8ab07f0d0ef6dd06081e4fa Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Thu, 31 Jul 2025 15:04:21 +0200
Subject: [PATCH] Update consistency level

---
 scywr/src/session.rs | 2 +-
 scywr/src/store.rs   | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/scywr/src/session.rs b/scywr/src/session.rs
index 768cc18..be9309c 100644
--- a/scywr/src/session.rs
+++ b/scywr/src/session.rs
@@ -27,7 +27,7 @@ impl From<NewSessionError> for Error {
 
 pub async fn create_session_no_ks(scyconf: &ScyllaIngestConfig) -> Result<Arc<Session>, Error> {
     let profile = ExecutionProfileBuilder::default()
-        .consistency(Consistency::LocalOne)
+        .consistency(Consistency::Any)
         .build()
         .into_handle();
     let port_range: RangeInclusive<u16> = 32000u16..=36000u16;
diff --git a/scywr/src/store.rs b/scywr/src/store.rs
index fdaef3d..c68d33b 100644
--- a/scywr/src/store.rs
+++ b/scywr/src/store.rs
@@ -4,6 +4,7 @@ use netpod::ttl::RetentionTime;
 use scylla::client::session::Session as ScySession;
 use scylla::errors::NewSessionError;
 use scylla::errors::PrepareError;
+use scylla::statement::Consistency;
 use scylla::statement::prepared::PreparedStatement;
 use std::sync::Arc;
 
@@ -181,13 +182,14 @@ impl DataStore {
             scy
         );
 
-        let q = scy
+        let mut q = scy
             .prepare(format!(
                 concat!("select * from {}{} limit 1"),
                 rett.table_prefix(),
                 "ts_msp"
             ))
             .await?;
+        q.set_consistency(Consistency::One);
         let qu_dummy = Arc::new(q);
 
         let ret = Self {