all: Run 'cargo fmt'

Author: lutter

graph/src/amp/codec/test_fixtures.rs

@@ -35,7 +35,8 @@ pub static RECORD_BATCH: LazyLock<RecordBatch> = LazyLock::new(|| {
 
     let columns = record_batches
         .into_iter()
-        .flat_map(|record_batch| record_batch.columns()).cloned()
+        .flat_map(|record_batch| record_batch.columns())
+        .cloned()
         .collect::<Vec<_>>();
 
     RecordBatch::try_new(Schema::try_merge(schemas).unwrap().into(), columns).unwrap()

graph/src/blockchain/firehose_block_stream.rs

@@ -465,40 +465,64 @@ mod tests {
 
         // Nothing
 
-        assert!(
-            !must_check_subgraph_continuity(&logger, &no_current_block, &no_cursor, 10),
-        );
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &no_current_block,
+            &no_cursor,
+            10
+        ),);
 
         // No cursor, subgraph current block ptr <, ==, > than manifest start block num
 
-        assert!(
-            !must_check_subgraph_continuity(&logger, &some_current_block(9), &no_cursor, 10),
-        );
-
-        assert!(
-            must_check_subgraph_continuity(&logger, &some_current_block(10), &no_cursor, 10),
-        );
-
-        assert!(
-            must_check_subgraph_continuity(&logger, &some_current_block(11), &no_cursor, 10),
-        );
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(9),
+            &no_cursor,
+            10
+        ),);
+
+        assert!(must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(10),
+            &no_cursor,
+            10
+        ),);
+
+        assert!(must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(11),
+            &no_cursor,
+            10
+        ),);
 
         // Some cursor, subgraph current block ptr <, ==, > than manifest start block num
 
-        assert!(
-            !must_check_subgraph_continuity(&logger, &no_current_block, &some_cursor, 10),
-        );
-
-        assert!(
-            !must_check_subgraph_continuity(&logger, &some_current_block(9), &some_cursor, 10),
-        );
-
-        assert!(
-            !must_check_subgraph_continuity(&logger, &some_current_block(10), &some_cursor, 10),
-        );
-
-        assert!(
-            !must_check_subgraph_continuity(&logger, &some_current_block(11), &some_cursor, 10),
-        );
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &no_current_block,
+            &some_cursor,
+            10
+        ),);
+
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(9),
+            &some_cursor,
+            10
+        ),);
+
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(10),
+            &some_cursor,
+            10
+        ),);
+
+        assert!(!must_check_subgraph_continuity(
+            &logger,
+            &some_current_block(11),
+            &some_cursor,
+            10
+        ),);
     }
 }

graph/src/data/store/scalar/bigdecimal.rs

@@ -631,7 +631,8 @@ mod test {
 
     #[test]
     fn big_decimal_stable() {
-        let cases = [(
+        let cases = [
+            (
                 "28b09c9c3f3e2fe037631b7fbccdf65c37594073016d8bf4bb0708b3fda8066a",
                 "0.1",
             ),
@@ -650,7 +651,8 @@ mod test {
             (
                 "6b06b34cc714810072988dc46c493c66a6b6c2c2dd0030271aa3adf3b3f21c20",
                 "98765587998098786876.0",
-            )];
+            ),
+        ];
         for (hash, s) in cases.iter() {
             let dec = BigDecimal::from_str(s).unwrap();
             assert_eq!(*hash, hex::encode(crypto_stable_hash(dec)));