This is an automated email from the ASF dual-hosted git repository. fokko pushed a commit to branch fd-speed-up-ci in repository https://gitbox.apache.org/repos/asf/iceberg-python.git
commit ffdf823d6c30d0d565d01ae8d0ad674592a8fe0f Author: Fokko Driesprong <[email protected]> AuthorDate: Sun Jun 30 20:29:13 2024 +0200 Don't refresh table in the for-loop This takes a lot of resources --- tests/integration/test_writes/test_partitioned_writes.py | 1 - 1 file changed, 1 deletion(-) diff --git a/tests/integration/test_writes/test_partitioned_writes.py b/tests/integration/test_writes/test_partitioned_writes.py index 76d559ca..f6e6e93c 100644 --- a/tests/integration/test_writes/test_partitioned_writes.py +++ b/tests/integration/test_writes/test_partitioned_writes.py @@ -170,7 +170,6 @@ def test_query_filter_appended_null_partitioned( assert tbl.format_version == format_version, f"Expected v{format_version}, got: v{tbl.format_version}" df = spark.table(identifier) for col in TEST_DATA_WITH_NULL.keys(): - df = spark.table(identifier) assert df.where(f"{col} is not null").count() == 6, f"Expected 6 non-null rows for {col}" assert df.where(f"{col} is null").count() == 3, f"Expected 3 null rows for {col}" # expecting 6 files: first append with [A], [B], [C], second append with [A, A], [B, B], [C, C]
