fmt

Author: alamb

datafusion/datasource/src/file_scan_config.rs

@@ -20,12 +20,15 @@
 
 use crate::file_groups::FileGroup;
 use crate::{
-    PartitionedFile, display::FileGroupsDisplay, file::FileSource,
+    PartitionedFile,
+    display::FileGroupsDisplay,
+    file::FileSource,
     file_compression_type::FileCompressionType,
     file_stream::{
         FileStreamBuilder, SharedFileStreamState, shared_file_stream_state_for,
     },
-    source::DataSource, statistics::MinMaxStatistics,
+    source::DataSource,
+    statistics::MinMaxStatistics,
 };
 use arrow::datatypes::FieldRef;
 use arrow::datatypes::{DataType, Schema, SchemaRef};
@@ -2520,7 +2523,10 @@ mod tests {
 
         // expect that reset_state clears the configuration
         let reset_exec = exec.reset_state().unwrap();
-        let reset_exec = reset_exec.as_any().downcast_ref::<DataSourceExec>().unwrap();
+        let reset_exec = reset_exec
+            .as_any()
+            .downcast_ref::<DataSourceExec>()
+            .unwrap();
         let reset_config = reset_exec
             .data_source()
             .as_any()

datafusion/datasource/src/source.rs

@@ -274,7 +274,9 @@ pub struct DataSourceExec {
 /// This helper is called whenever a new `DataSourceExec` is constructed or
 /// rebuilt so runtime-only shared scheduler state does not leak across plan
 /// recreations such as [`ExecutionPlan::reset_state`].
-fn attach_shared_file_stream_state(data_source: Arc<dyn DataSource>) -> Arc<dyn DataSource> {
+fn attach_shared_file_stream_state(
+    data_source: Arc<dyn DataSource>,
+) -> Arc<dyn DataSource> {
     if let Some(config) = data_source.as_any().downcast_ref::<FileScanConfig>() {
         data_source
             .with_new_state(Arc::new(shared_file_stream_state_for(config)))