Restrict one before range

crates/daqbuffer/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "daqretrieve"
-version = "0.5.5-aa.18"
+version = "0.5.5"
 authors = ["Dominik Werder <dominik.werder@gmail.com>"]
 edition = "2024"
 

crates/scyllaconn/src/events2/events.rs

@@ -918,6 +918,13 @@ async fn read_lsp_all(
     jobtrace: &mut ReadJobTrace,
 ) -> Result<(Vec<DtNano>,), Error> {
     let selfname = "read_lsp_all";
+    let lsp_max = if opts.ts_msp.ns() >= opts.range.beg() {
+        // TODO should not happen
+        // TODO metrics
+        return Ok((Vec::new(),));
+    } else {
+        opts.range.beg().delta(opts.ts_msp.ns())
+    };
     let mut qu = stmts
         .rt(&opts.rt)
         .lsp_all()
@@ -933,7 +940,9 @@ async fn read_lsp_all(
     let mut it = res.rows_stream::<(i64,)>()?;
     while let Some(row) = it.try_next().await? {
         let lsp = DtNano::from_ns(row.0 as u64);
-        ret.push(lsp);
+        if lsp < lsp_max {
+            ret.push(lsp);
+        }
     }
     Ok((ret,))
 }

crates/scyllaconn/src/events2/msp.rs

@@ -365,9 +365,7 @@ async fn find_ts_msp_bck(
     Ok(ret)
 }
 
-/*
+// Workaround because scylla's order by desc is broken at the moment.
-Workaround because scylla's order by desc is broken at the moment.
-*/
 async fn find_ts_msp_bck_workaround(
     rt: &RetentionTime,
     series: u64,