format

supabase · Nov 30, 2024 · 15fecf6 · 15fecf6
1 parent a4bcd32
commit 15fecf6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pg_replicate/src/pipeline/batching/data_pipeline.rs b/pg_replicate/src/pipeline/batching/data_pipeline.rs
@@ -3,7 +3,7 @@ use std::{collections::HashSet, time::Instant};
 use futures::StreamExt;
 use tokio::pin;
 use tokio_postgres::types::PgLsn;
-use tracing::{debug, info, warn};
+use tracing::{debug, info};
 
 use crate::{
     conversions::cdc_event::{CdcEvent, CdcEventConversionError},

diff --git a/pg_replicate/src/pipeline/sinks/bigquery.rs b/pg_replicate/src/pipeline/sinks/bigquery.rs
@@ -9,7 +9,7 @@ use tracing::info;
 use crate::{
     clients::bigquery::BigQueryClient,
     conversions::{cdc_event::CdcEvent, table_row::TableRow, Cell},
-    pipeline::{PipelineResumptionState, sources::postgres::TableCopyStreamError},
+    pipeline::{sources::postgres::TableCopyStreamError, PipelineResumptionState},
     table::{ColumnSchema, TableId, TableName, TableSchema},
 };
 

diff --git a/pg_replicate/src/pipeline/sinks/stdout.rs b/pg_replicate/src/pipeline/sinks/stdout.rs
@@ -10,7 +10,7 @@ use crate::{
     table::{TableId, TableSchema},
 };
 
-use super::{Sink, SinkError, InfallibleSinkError};
+use super::{InfallibleSinkError, Sink, SinkError};
 
 pub struct StdoutSink;