diff --git a/crates/nodenet/src/scylla.rs b/crates/nodenet/src/scylla.rs index 7818958..84db512 100644 --- a/crates/nodenet/src/scylla.rs +++ b/crates/nodenet/src/scylla.rs @@ -36,7 +36,7 @@ pub async fn scylla_channel_event_stream( chconf: ChConf, scyqueue: &ScyllaQueue, ) -> Result> + Send>>, Error> { - debug!("scylla_channel_event_stream {evq:?}"); + trace!("scylla_channel_event_stream {evq:?}"); // TODO depends in general on the query // TODO why both in PlainEventsQuery and as separate parameter? Check other usages. let _series = SeriesId::new(chconf.series()); diff --git a/crates/scyllaconn/src/bincache.rs b/crates/scyllaconn/src/bincache.rs index 953d820..2af4f31 100644 --- a/crates/scyllaconn/src/bincache.rs +++ b/crates/scyllaconn/src/bincache.rs @@ -46,7 +46,7 @@ pub async fn worker_write( stmts_cache: &StmtsCache, scy: &ScySession, ) -> Result<(), streams::timebin::cached::reader::Error> { - for (((((((&ts1, &ts2), &cnt), min), max), &avg), lst), &fnl) in bins.zip_iter() { + for (((((((&ts1, &ts2), &cnt), min), max), avg), lst), &fnl) in bins.zip_iter() { let bin_len = DtMs::from_ms_u64((ts2.ns() - ts1.ns()) / 1000000); let div = streams::timebin::cached::reader::part_len(bin_len).ns(); let msp = ts1.ns() / div;