Revert "add logging to help troubleshoot"

This reverts commit 0cf109e.
supabase · Nov 30, 2024 · f9ffb43 · f9ffb43
1 parent 39bc3cf
commit f9ffb43
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/pg_replicate/src/conversions/table_row.rs b/pg_replicate/src/conversions/table_row.rs
@@ -3,7 +3,7 @@ use std::str::Utf8Error;
 
 use thiserror::Error;
 use tokio_postgres::types::Type;
-use tracing::{error, info};
+use tracing::error;
 
 use crate::{conversions::text::TextFormatConverter, pipeline::batching::BatchBoundary};
 
@@ -48,7 +48,6 @@ impl TableRowConverter {
         let mut values = Vec::with_capacity(column_schemas.len());
 
         let row_str = str::from_utf8(row)?;
-        info!("row_str: {row_str}");
         let mut column_schemas_iter = column_schemas.iter();
         let mut chars = row_str.chars();
         let mut val_str = String::with_capacity(10);
@@ -94,7 +93,6 @@ impl TableRowConverter {
                     return Err(TableRowConversionError::NumColsMismatch);
                 };
 
-                info!("val_str: {val_str:#?}");
                 let value = if val_str == "\\N" {
                     Cell::Null
                 } else {

diff --git a/pg_replicate/src/pipeline/batching/data_pipeline.rs b/pg_replicate/src/pipeline/batching/data_pipeline.rs
@@ -60,8 +60,6 @@ impl<Src: Source, Snk: BatchSink> BatchDataPipeline<Src, Snk> {
                 continue;
             }
 
-            info!("table schema: {table_schema:#?}");
-
             self.sink.truncate_table(table_schema.table_id).await?;
 
             let table_rows = self