add logging to help troubleshoot

supabase · Nov 30, 2024 · 0cf109e · 0cf109e
1 parent 83e47b2
commit 0cf109e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
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;
+use tracing::{error, info};
 
 use crate::{conversions::text::TextFormatConverter, pipeline::batching::BatchBoundary};
 
@@ -48,6 +48,7 @@ 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);
@@ -93,6 +94,7 @@ 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
@@ -56,6 +56,8 @@ 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