fmt

Author: gotocoding-DB

kernel/src/engine/default/mod.rs

@@ -85,7 +85,11 @@ impl<E: TaskExecutor> DefaultEngine<E> {
     {
         // table root is the path of the table in the ObjectStore
         let (object_store, _table_root) = parse_url_opts(table_root, options)?;
-        Ok(Self::new_with_metrics(Arc::new(object_store), task_executor, reporter))
+        Ok(Self::new_with_metrics(
+            Arc::new(object_store),
+            task_executor,
+            reporter,
+        ))
     }
 
     /// Create a new [`DefaultEngine`] instance
@@ -94,10 +98,7 @@ impl<E: TaskExecutor> DefaultEngine<E> {
     ///
     /// - `object_store`: The object store to use.
     /// - `task_executor`: Used to spawn async IO tasks. See [executor::TaskExecutor].
-    pub fn new(
-        object_store: Arc<DynObjectStore>,
-        task_executor: Arc<E>,
-    ) -> Self {
+    pub fn new(object_store: Arc<DynObjectStore>, task_executor: Arc<E>) -> Self {
         Self::new_with_metrics(object_store, task_executor, None)
     }
 
@@ -222,8 +223,7 @@ mod tests {
         let tmp = tempfile::tempdir().unwrap();
         let url = Url::from_directory_path(tmp.path()).unwrap();
         let object_store = Arc::new(LocalFileSystem::new());
-        let engine =
-            DefaultEngine::new(object_store, Arc::new(TokioBackgroundExecutor::new()));
+        let engine = DefaultEngine::new(object_store, Arc::new(TokioBackgroundExecutor::new()));
         test_arrow_engine(&engine, &url);
     }
 

kernel/src/snapshot/builder.rs

@@ -87,9 +87,15 @@ impl SnapshotBuilder {
         let operation_id = MetricId::new();
         let reporter = engine.get_metrics_reporter();
 
-        let table_path = self.table_root.as_ref()
+        let table_path = self
+            .table_root
+            .as_ref()
             .map(|url| url.to_string())
-            .or_else(|| self.existing_snapshot.as_ref().map(|s| s.table_root().to_string()))
+            .or_else(|| {
+                self.existing_snapshot
+                    .as_ref()
+                    .map(|s| s.table_root().to_string())
+            })
             .unwrap_or_else(|| "unknown".to_string());
 
         if let Some(ref r) = reporter {