diff --git a/kernel/src/scan/log_replay.rs b/kernel/src/scan/log_replay.rs index 428de6b9d..bce3fde2b 100644 --- a/kernel/src/scan/log_replay.rs +++ b/kernel/src/scan/log_replay.rs @@ -292,16 +292,16 @@ mod tests { &[true, false], (), validate_simple, - ); + ).unwrap(); } #[test] fn test_scan_action_iter_with_remove() { - run_with_validate_callback( + let _ = run_with_validate_callback( vec![add_batch_with_remove()], &[false, false, true, false], (), validate_simple, - ); + ).unwrap(); } } diff --git a/kernel/src/scan/mod.rs b/kernel/src/scan/mod.rs index 75daa1a24..bebc25817 100644 --- a/kernel/src/scan/mod.rs +++ b/kernel/src/scan/mod.rs @@ -703,7 +703,6 @@ pub(crate) mod test_utils { sync::{json::SyncJsonHandler, SyncEngine}, }, scan::log_replay::scan_action_iter, - schema::{StructField, StructType}, DeltaResult, EngineData, JsonHandler, }; @@ -757,13 +756,6 @@ pub(crate) mod test_utils { context: T, validate_callback: ScanCallback, ) -> DeltaResult<()> { - let engine = SyncEngine::new(); - // doesn't matter here - let table_schema = Arc::new(StructType::new([StructField::new( - "foo", - crate::schema::DataType::STRING, - false, - )])); let iter = scan_action_iter( &SyncEngine::new(), batch.into_iter().map(|batch| Ok((batch as _, true))), diff --git a/kernel/src/scan/state.rs b/kernel/src/scan/state.rs index 12bbed552..d89210621 100644 --- a/kernel/src/scan/state.rs +++ b/kernel/src/scan/state.rs @@ -253,6 +253,6 @@ mod tests { &[true, false], context, validate_visit, - ); + ).unwrap(); } }