Skip to content

Commit 911437e

Browse files
Move print test to non-acceptance test
1 parent 2d763b5 commit 911437e

File tree

5 files changed

+9
-5
lines changed

5 files changed

+9
-5
lines changed

kernel/Cargo.toml

+1
Original file line numberDiff line numberDiff line change
@@ -123,3 +123,4 @@ tracing-subscriber = { version = "0.3", default-features = false, features = [
123123
"env-filter",
124124
"fmt",
125125
] }
126+
env_logger = "0.11.5"

kernel/src/engine/default/json.rs

-1
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,6 @@ impl<E: TaskExecutor> JsonHandler for DefaultJsonHandler<E> {
122122
physical_schema: SchemaRef,
123123
predicate: Option<Expression>,
124124
) -> DeltaResult<FileDataReadResultIterator> {
125-
debug!("Reading json files with predicate: {:?}", predicate);
126125
if files.is_empty() {
127126
return Ok(Box::new(std::iter::empty()));
128127
}

kernel/src/engine/sync/json.rs

+5-2
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,12 @@ impl JsonHandler for SyncJsonHandler {
4141
&self,
4242
files: &[FileMeta],
4343
schema: SchemaRef,
44-
_predicate: Option<Expression>,
44+
predicate: Option<Expression>,
4545
) -> DeltaResult<FileDataReadResultIterator> {
46-
debug!("Reading json files: {:#?}", files);
46+
debug!(
47+
"Reading json files: {:#?} with predicate {:#?}",
48+
files, predicate
49+
);
4750
if files.is_empty() {
4851
return Ok(Box::new(std::iter::empty()));
4952
}

kernel/src/engine/sync/parquet.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -38,9 +38,9 @@ impl ParquetHandler for SyncParquetHandler {
3838
&self,
3939
files: &[FileMeta],
4040
schema: SchemaRef,
41-
_predicate: Option<Expression>,
41+
predicate: Option<Expression>,
4242
) -> DeltaResult<FileDataReadResultIterator> {
43-
debug!("Reading parquet files: {files:#?} with schema {schema:#?}");
43+
debug!("Reading parquet files: {files:#?} with schema {schema:#?} and predicate {predicate:#?}");
4444
if files.is_empty() {
4545
return Ok(Box::new(std::iter::empty()));
4646
}

kernel/src/scan/mod.rs

+1
Original file line numberDiff line numberDiff line change
@@ -627,6 +627,7 @@ mod tests {
627627

628628
#[test]
629629
fn test_scan_data() {
630+
env_logger::init();
630631
let path =
631632
std::fs::canonicalize(PathBuf::from("./tests/data/table-without-dv-small/")).unwrap();
632633
let url = url::Url::from_directory_path(path).unwrap();

0 commit comments

Comments
 (0)