From 6dbbe07d2866cf0247a7bfffdd0e2128f80c5828 Mon Sep 17 00:00:00 2001 From: Nikolay Ulmasov Date: Fri, 29 Dec 2023 14:44:56 +0000 Subject: [PATCH] remove patitioning from replace_where test Signed-off-by: Nikolay Ulmasov --- crates/deltalake-core/tests/command_restore.rs | 7 +++++-- python/tests/test_writer.py | 4 +--- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/crates/deltalake-core/tests/command_restore.rs b/crates/deltalake-core/tests/command_restore.rs index 800de71f00..0f76dfaef5 100644 --- a/crates/deltalake-core/tests/command_restore.rs +++ b/crates/deltalake-core/tests/command_restore.rs @@ -131,10 +131,13 @@ async fn test_restore_by_datetime() -> Result<(), Box> { .unwrap() .as_millis(); if now as i64 <= datetime.timestamp_millis() { - println!("--> Now: {} < history[1].timestamp: {}", now, datetime.timestamp_millis()); + println!( + "--> Now: {} < history[1].timestamp: {}", + now, + datetime.timestamp_millis() + ); } assert!(now as i64 > datetime.timestamp_millis()); - let result = DeltaOps(table) .restore() diff --git a/python/tests/test_writer.py b/python/tests/test_writer.py index ec9a843b85..7111d70577 100644 --- a/python/tests/test_writer.py +++ b/python/tests/test_writer.py @@ -884,9 +884,7 @@ def test_replace_where_overwrite( "val": pa.array([1, 1, 1, 1], pa.int64()), } ) - write_deltalake( - table_path, sample_data, mode="overwrite", partition_by=["p1", "p2"] - ) + write_deltalake(table_path, sample_data, mode="overwrite") delta_table = DeltaTable(table_path) assert (