diff --git a/crates/miroir-core/src/migration.rs b/crates/miroir-core/src/migration.rs index 60fcad6..0607954 100644 --- a/crates/miroir-core/src/migration.rs +++ b/crates/miroir-core/src/migration.rs @@ -495,7 +495,11 @@ impl MigrationCoordinator { } // Clear only the in-flight writes for this migration - let affected_shards = state.affected_shards.keys().cloned().collect::>(); + let affected_shards = state + .affected_shards + .keys() + .cloned() + .collect::>(); self.in_flight .retain(|w| !affected_shards.contains(&w.shard));