Apply clippy fixes

getdozer · Mar 28, 2024 · 6de3ac5 · 6de3ac5
1 parent 2659935
commit 6de3ac5
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/dozer-sink-aerospike/src/aerospike.rs b/dozer-sink-aerospike/src/aerospike.rs
@@ -310,7 +310,7 @@ impl Client {
         &self,
         batch: *mut as_batch_records,
     ) -> Result<(), AerospikeError> {
-        info!("Batch get {} records", (*batch).list.size);
+        dbg!("Batch get {} records", (*batch).list.size);
         as_try(|err| aerospike_batch_read(self.inner.as_ptr(), err, std::ptr::null(), batch))
     }
 

diff --git a/dozer-sink-aerospike/src/denorm_dag.rs b/dozer-sink-aerospike/src/denorm_dag.rs
@@ -10,7 +10,7 @@ use dozer_core::petgraph::visit::{
     EdgeRef, IntoEdgesDirected, IntoNeighborsDirected, IntoNodeReferences,
 };
 use dozer_types::indexmap::IndexMap;
-use dozer_types::log::info;
+use dozer_types::log::debug;
 use dozer_types::models::sink::{AerospikeSet, AerospikeSinkTable};
 use dozer_types::thiserror;
 use dozer_types::types::{Field, Record, Schema, TableOperation};
@@ -499,7 +499,7 @@ impl DenormalizationState {
             .sum();
 
         let batch_size: u32 = batch_size_upper_bound.try_into().unwrap();
-        info!("Writing denorm batch of size {}", batch_size);
+        debug!(target: "aerospike_sink", "Writing denorm batch of size {}", batch_size);
         let mut write_batch = RecordBatch::new(batch_size, batch_size);
 
         for node in self.dag.node_weights_mut() {

diff --git a/dozer-sink-aerospike/src/lib.rs b/dozer-sink-aerospike/src/lib.rs
@@ -3,7 +3,7 @@ pub use crate::aerospike::Client;
 use aerospike_client_sys::*;
 use denorm_dag::DenormalizationState;
 use dozer_core::event::EventHub;
-use dozer_types::log::{error, info};
+use dozer_types::log::{debug, error};
 use dozer_types::models::connection::AerospikeConnection;
 use dozer_types::node::OpIdentifier;
 use dozer_types::thiserror;
@@ -440,7 +440,7 @@ impl AerospikeSinkWorker {
         // Write denormed tables
         let mut batch = RecordBatch::new(batch_size_est as u32, batch_size_est as u32);
 
-        info!("Sink batch size {batch_size_est}");
+        debug!(target: "aerospike_sink", "Sink batch size {batch_size_est}");
         for table in denormalized_tables {
             for (key, record) in table.records {
                 batch.add_write(