Skip to content

Commit f62a7a8

Browse files
committed
add test
1 parent df7d65e commit f62a7a8

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

python/tests/test_dataframe.py

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -731,9 +731,7 @@ def test_optimized_logical_plan(aggregate_df):
731731
def test_execution_plan(aggregate_df):
732732
plan = aggregate_df.execution_plan()
733733

734-
expected = (
735-
"AggregateExec: mode=FinalPartitioned, gby=[c1@0 as c1], aggr=[sum(test.c2)]\n" # noqa: E501
736-
)
734+
expected = "AggregateExec: mode=FinalPartitioned, gby=[c1@0 as c1], aggr=[sum(test.c2)]\n" # noqa: E501
737735

738736
assert expected == plan.display()
739737

@@ -1107,7 +1105,15 @@ def test_write_compressed_parquet_wrong_compression_level(
11071105
)
11081106

11091107

1110-
@pytest.mark.parametrize("compression", ["brotli", "zstd", "wrong"])
1108+
# test write_parquet with zstd, brotli default compression level, should complete without error
1109+
@pytest.mark.parametrize("compression", ["zstd", "brotli"])
1110+
def test_write_compressed_parquet_default_compression_level(df, tmp_path, compression):
1111+
path = tmp_path
1112+
1113+
df.write_parquet(str(path), compression=compression)
1114+
1115+
1116+
@pytest.mark.parametrize("compression", ["wrong"])
11111117
def test_write_compressed_parquet_missing_compression_level(df, tmp_path, compression):
11121118
path = tmp_path
11131119

0 commit comments

Comments
 (0)