Fix field typo, small cleanup

scywr/src/insertworker.rs

@@ -202,10 +202,6 @@ async fn worker_streamed(
         let stream = stream
             .map(|x| futures_util::stream::iter(x))
             .flatten_unordered(Some(1))
-            // .map(|x| async move {
-            //     drop(x);
-            //     Ok(())
-            // })
             .buffer_unordered(concurrency);
         let mut stream = Box::pin(stream);
         debug_setup!("waiting for item");

scywr/src/store.rs

@@ -151,7 +151,7 @@ impl DataStore {
 
         let qu_insert_binned_scalar_f32_v02 = prep_qu_ins_c!(
             "binned_scalar_f32_v02",
-            "series, binlen, msp, off, count, min, max, avg, dev",
+            "series, binlen, msp, off, cnt, min, max, avg, dev",
             "?, ?, ?, ?, ?, ?, ?, ?, ?",
             rett,
             scy

serieswriter/src/binwriter.rs

@@ -62,8 +62,6 @@ impl BinWriter {
                     DtMs::from_ms_u64(1000 * 60 * 1)
                 } else if dur < Duration::from_millis(1000 * 60 * 20) {
                     DtMs::from_ms_u64(1000 * 60 * 10)
-                } else if dur < Duration::from_millis(1000 * 60 * 60 * 2) {
-                    DtMs::from_ms_u64(1000 * 60 * 60 * 1)
                 } else {
                     DtMs::from_ms_u64(1000 * 60 * 60 * 1)
                 };

serieswriter/src/binwritergrid.rs

@@ -110,7 +110,6 @@ impl BinWriterGrid {
                 } else if bin_len == DtMs::from_ms_u64(1000 * 60 * 60 * 1) {
                     DtMs::from_ms_u64(1000 * 60 * 60 * 24 * 28)
                 } else {
-                    // TODO
                     return Err(Error::UnsupportedBinGrid(bin_len));
                 };
                 if div.ns() % bin_len.ns() != 0 {