style: rustfmt

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: g-talbot

quickwit/quickwit-metastore/src/metastore/file_backed/file_backed_index/mod.rs

@@ -980,15 +980,15 @@ fn metrics_split_matches_query(split: &StoredMetricsSplit, query: &ListMetricsSp
     }
 
     // Filter by compaction scope
-    if let Some(ws) = query.window_start {
-        if split.metadata.window_start != Some(ws) {
-            return false;
-        }
+    if let Some(ws) = query.window_start
+        && split.metadata.window_start != Some(ws)
+    {
+        return false;
     }
-    if let Some(ref sf) = query.sort_fields {
-        if split.metadata.sort_fields != *sf {
-            return false;
-        }
+    if let Some(ref sf) = query.sort_fields
+        && split.metadata.sort_fields != *sf
+    {
+        return false;
     }
 
     true

quickwit/quickwit-metastore/src/metastore/postgres/metastore.rs

@@ -75,9 +75,9 @@ use crate::file_backed::MutationOccurred;
 use crate::metastore::postgres::model::Shards;
 use crate::metastore::postgres::utils::split_maturity_timestamp;
 use crate::metastore::{
-    IndexesMetadataResponseExt, ListMetricsSplitsRequestExt, ListMetricsSplitsResponseExt,
-    PublishMetricsSplitsRequestExt, PublishSplitsRequestExt, STREAM_SPLITS_CHUNK_SIZE,
-    StageMetricsSplitsRequestExt, UpdateSourceRequestExt, use_shard_api,
+    IndexesMetadataResponseExt, ListMetricsSplitsResponseExt, PublishMetricsSplitsRequestExt,
+    PublishSplitsRequestExt, STREAM_SPLITS_CHUNK_SIZE, StageMetricsSplitsRequestExt,
+    UpdateSourceRequestExt, use_shard_api,
 };
 use crate::{
     AddSourceRequestExt, CreateIndexRequestExt, IndexMetadata, IndexMetadataResponseExt,
@@ -1804,7 +1804,8 @@ impl MetastoreService for PostgresqlMetastore {
         let mut size_bytes_list = Vec::with_capacity(splits_metadata.len());
         let mut split_metadata_jsons = Vec::with_capacity(splits_metadata.len());
         let mut window_starts: Vec<Option<i64>> = Vec::with_capacity(splits_metadata.len());
-        let mut window_duration_secs_list: Vec<Option<i32>> = Vec::with_capacity(splits_metadata.len());
+        let mut window_duration_secs_list: Vec<Option<i32>> =
+            Vec::with_capacity(splits_metadata.len());
         let mut sort_fields_list: Vec<String> = Vec::with_capacity(splits_metadata.len());
         let mut num_merge_ops_list: Vec<i32> = Vec::with_capacity(splits_metadata.len());
         let mut row_keys_list: Vec<Option<Vec<u8>>> = Vec::with_capacity(splits_metadata.len());

quickwit/quickwit-parquet-engine/src/storage/writer.rs

@@ -709,9 +709,10 @@ mod tests {
     fn test_meta07_self_describing_parquet_roundtrip() {
         use std::fs::File;
 
-        use crate::split::{SplitId, TimeRange};
         use parquet::file::reader::{FileReader, SerializedFileReader};
 
+        use crate::split::{SplitId, TimeRange};
+
         let sort_schema_str = "metric_name|host|env|timestamp/V2";
         let window_start_secs: i64 = 1700006400;
         let window_duration: u32 = 900;
@@ -768,8 +769,8 @@ mod tests {
             .expect("self-describing file must contain qh.num_merge_ops")
             .parse()
             .expect("num_merge_ops must be parseable as u32");
-        let recovered_row_keys_b64 = find_kv(PARQUET_META_ROW_KEYS)
-            .expect("self-describing file must contain qh.row_keys");
+        let recovered_row_keys_b64 =
+            find_kv(PARQUET_META_ROW_KEYS).expect("self-describing file must contain qh.row_keys");
         let recovered_row_keys = BASE64
             .decode(&recovered_row_keys_b64)
             .expect("row_keys must be valid base64");