Skip to content

Commit

Permalink
fix all the warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
cg-cognition committed Dec 11, 2024
1 parent 91bfcd8 commit 7d03266
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 12 deletions.
6 changes: 3 additions & 3 deletions kernel/src/scan/log_replay.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
}
8 changes: 0 additions & 8 deletions kernel/src/scan/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
};

Expand Down Expand Up @@ -757,13 +756,6 @@ pub(crate) mod test_utils {
context: T,
validate_callback: ScanCallback<T>,
) -> 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))),
Expand Down
2 changes: 1 addition & 1 deletion kernel/src/scan/state.rs
Original file line number Diff line number Diff line change
Expand Up @@ -253,6 +253,6 @@ mod tests {
&[true, false],
context,
validate_visit,
);
).unwrap();
}
}

0 comments on commit 7d03266

Please sign in to comment.