Skip to content

Commit 99fe733

Browse files
committed
ignore pyiceberg test by default
1 parent 176a059 commit 99fe733

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

datafusion_iceberg/tests/integration_pyiceberg.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ fn configure_python_venv(py: Python) -> PyResult<()> {
3636
}
3737

3838
#[tokio::test]
39+
#[ignore]
3940
async fn test_pyiceberg_integration() {
4041
let temp_dir = TempDir::new().unwrap();
4142
let warehouse_path = temp_dir.path().join("warehouse");
@@ -273,19 +274,19 @@ async fn test_pyiceberg_integration() {
273274
.expect("Failed to extract column_names");
274275

275276
assert!(
276-
column_names.contains(&"L_PARTKEY".to_string()),
277+
column_names.contains(&"l_partkey".to_string()),
277278
"Column L_PARTKEY not found"
278279
);
279280
assert!(
280-
column_names.contains(&"L_QUANTITY".to_string()),
281+
column_names.contains(&"l_quantity".to_string()),
281282
"Column L_QUANTITY not found"
282283
);
283284

284285
println!("✓ PyIceberg table has correct columns: {:?}", column_names);
285286

286287
// Get specific column
287288
let l_partkey_column = arrow_table
288-
.call_method1("column", ("L_PARTKEY",))
289+
.call_method1("column", ("l_partkey",))
289290
.expect("Failed to get L_PARTKEY column");
290291

291292
let partkey_values: Vec<i64> = l_partkey_column

0 commit comments

Comments
 (0)