Update consistency level

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;

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 {