fix

Author: gotocoding-DB

kernel/src/engine/default/filesystem.rs

@@ -309,12 +309,10 @@ impl<E: TaskExecutor> StorageHandler for ObjectStoreStorageHandler<E> {
             Ok(())
         });
 
-        if result.is_ok() {
-            if let Some(ref r) = reporter {
-                r.report(MetricEvent::StorageCopyCompleted {
-                    duration: timer.elapsed(),
-                });
-            }
+        if let Some(ref r) = reporter {
+            r.report(MetricEvent::StorageCopyCompleted {
+                duration: timer.elapsed(),
+            });
         }
 
         result

kernel/src/metrics/mod.rs

@@ -14,6 +14,7 @@
 //! use std::sync::Arc;
 //! use delta_kernel::metrics::{MetricsReporter, MetricEvent};
 //!
+//! #[derive(Debug)]
 //! struct LoggingReporter;
 //!
 //! impl MetricsReporter for LoggingReporter {
@@ -45,6 +46,7 @@
 //! use std::sync::Arc;
 //! use delta_kernel::metrics::{MetricsReporter, MetricEvent};
 //!
+//! #[derive(Debug)]
 //! struct CompositeReporter {
 //!     reporters: Vec<Arc<dyn MetricsReporter>>,
 //! }

kernel/src/snapshot/builder.rs

@@ -195,7 +195,10 @@ mod tests {
     ) {
         let table_root = Url::parse("memory:///test_table").unwrap();
         let store = Arc::new(InMemory::new());
-        let engine = Arc::new(DefaultEngine::new(store.clone(), Arc::new(TokioBackgroundExecutor::new())));
+        let engine = Arc::new(DefaultEngine::new(
+            store.clone(),
+            Arc::new(TokioBackgroundExecutor::new()),
+        ));
         (engine, store, table_root)
     }