fmt

Author: adriangb

src/flight_service/do_get.rs

@@ -141,10 +141,9 @@ impl ArrowFlightEndpoint {
         }
 
         let stream =
-            encoder_builder
-                .build(stream.map_err(|err| {
-                    FlightError::Tonic(Box::new(datafusion_error_to_tonic_status(&err)))
-                }));
+            encoder_builder.build(stream.map_err(|err| {
+                FlightError::Tonic(Box::new(datafusion_error_to_tonic_status(&err)))
+            }));
 
         let task_data_entries = Arc::clone(&self.task_data_entries);
         let num_partitions_remaining = Arc::clone(&stage_data.num_partitions_remaining);