simplify driver

Author: OussamaSaoudi

kernel/src/distributed/driver.rs

@@ -75,7 +75,7 @@ pub(crate) struct DriverProcessor<P: LogReplayProcessor> {
 }
 
 /// Result of driver phase processing.
-#[allow(unused)] 
+#[allow(unused)]
 pub(crate) enum DriverProcessorResult<P: LogReplayProcessor> {
     /// All processing complete on driver - no executor phase needed.
     Complete(P),
@@ -90,7 +90,7 @@ impl<P: LogReplayProcessor> DriverProcessor<P> {
     /// - `processor`: The log replay processor
     /// - `log_segment`: The log segment to process
     /// - `engine`: Engine for reading files
-    #[allow(unused)] 
+    #[allow(unused)]
     pub(crate) fn try_new(
         processor: P,
         log_segment: Arc<LogSegment>,
@@ -120,7 +120,7 @@ impl<P: LogReplayProcessor> DriverProcessor<P> {
             log_segment,
         })
     }
-    
+
     /// Complete driver phase and extract processor + files for distribution.
     ///
     /// Must be called after the iterator is exhausted.
@@ -190,7 +190,9 @@ mod tests {
     use super::*;
     use crate::scan::log_replay::ScanLogReplayProcessor;
     use crate::scan::state_info::StateInfo;
-    use crate::utils::test_utils::{assert_result_error_with_message, load_extracted_test_table, load_test_table_with_data};
+    use crate::utils::test_utils::{
+        assert_result_error_with_message, load_extracted_test_table, load_test_table_with_data,
+    };
     use crate::{Engine, SnapshotRef};
     use std::sync::Arc;