From 19a240169c99bcf44fcc67c6aaaf63de3092a098 Mon Sep 17 00:00:00 2001 From: Fokko Driesprong Date: Thu, 4 Jul 2024 06:59:31 +0200 Subject: [PATCH] Don't refresh table in the for-loop (#874) --- 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 76d559ca57..f6e6e93c11 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]