diff --git a/crates/weaver-index/src/clickhouse.rs b/crates/weaver-index/src/clickhouse.rs
index 0685c0a..e0e2cbb 100644
--- a/crates/weaver-index/src/clickhouse.rs
+++ b/crates/weaver-index/src/clickhouse.rs
@@ -6,7 +6,9 @@ mod schema;
 
 pub use client::{Client, TableSize};
 pub use migrations::{DbObject, MigrationResult, Migrator, ObjectType};
-pub use queries::{EntryRow, HandleMappingRow, NotebookRow, ProfileCountsRow, ProfileRow, ProfileWithCounts};
+pub use queries::{
+    EntryRow, HandleMappingRow, NotebookRow, ProfileCountsRow, ProfileRow, ProfileWithCounts,
+};
 pub use resilient_inserter::{InserterConfig, ResilientRecordInserter};
 pub use schema::{
     AccountRevState, FirehoseCursor, RawAccountEvent, RawEventDlq, RawIdentityEvent,
diff --git a/crates/weaver-index/src/parallel_tap.rs b/crates/weaver-index/src/parallel_tap.rs
index 5ce15df..93ac006 100644
--- a/crates/weaver-index/src/parallel_tap.rs
+++ b/crates/weaver-index/src/parallel_tap.rs
@@ -1,5 +1,5 @@
-use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
+use std::sync::atomic::{AtomicBool, Ordering};
 use std::time::{Duration, Instant};
 
 use chrono::Utc;
@@ -7,9 +7,8 @@ use smol_str::{SmolStr, ToSmolStr};
 use tokio::task::JoinHandle;
 use tracing::{debug, error, info, trace, warn};
 
-use crate::clickhouse::migrations::Migrator;
 use crate::clickhouse::{
-    Client, InserterConfig, RawIdentityEvent, RawRecordInsert, ResilientRecordInserter,
+    Client, InserterConfig, Migrator, RawIdentityEvent, RawRecordInsert, ResilientRecordInserter,
 };
 use crate::config::{IndexerConfig, TapConfig};
 use crate::error::{ClickHouseError, Result};
@@ -239,10 +238,7 @@ async fn run_tap_worker(
                         .compare_exchange(false, true, Ordering::SeqCst, Ordering::SeqCst)
                         .is_ok()
                 {
-                    info!(
-                        worker_id,
-                        "first live event received, scheduling backfill"
-                    );
+                    info!(worker_id, "first live event received, scheduling backfill");
                     let backfill_client = client.clone();
                     tokio::spawn(async move {
                         run_backfill(backfill_client).await;
@@ -310,7 +306,10 @@ async fn run_backfill(client: Arc<Client>) {
         return;
     }
 
-    info!(count = mvs.len(), "backfill: starting incremental MV backfill");
+    info!(
+        count = mvs.len(),
+        "backfill: starting incremental MV backfill"
+    );
 
     for mv in mvs {
         info!(