chore: lint/fmt

influxdata · May 30, 2024 · c976ad1 · c976ad1
1 parent 484b2fd
commit c976ad1
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/datafusion/core/src/datasource/physical_plan/parquet/row_filter.rs b/datafusion/core/src/datasource/physical_plan/parquet/row_filter.rs
@@ -524,12 +524,12 @@ mod test {
             .expect("building candidate")
             .expect("candidate expected");
 
-        let schema_adapter = DefaultSchemaAdapterFactory{}.create(Arc::new(table_schema));
+        let schema_adapter =
+            DefaultSchemaAdapterFactory {}.create(Arc::new(table_schema));
         let (schema_mapping, _) = schema_adapter
             .map_schema(&file_schema)
             .expect("creating schema mapping");
 
-
         let mut row_filter = DatafusionArrowPredicate::try_new(
             candidate,
             &file_schema,
@@ -560,7 +560,7 @@ mod test {
 
         let filtered = row_filter.evaluate(record_batch);
 
-        assert!(matches!(filtered, Ok(_)));
+        assert!(filtered.is_ok());
     }
 
     #[test]

diff --git a/datafusion/core/src/datasource/schema_adapter.rs b/datafusion/core/src/datasource/schema_adapter.rs
@@ -372,7 +372,10 @@ mod tests {
             Ok(RecordBatch::try_new(schema, new_columns).unwrap())
         }
 
-        fn map_partial_batch(&self, batch: RecordBatch) -> datafusion_common::Result<RecordBatch> {
+        fn map_partial_batch(
+            &self,
+            batch: RecordBatch,
+        ) -> datafusion_common::Result<RecordBatch> {
             self.map_batch(batch)
         }
     }