Skip to content

Commit

Permalink
Fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
jonashaag committed Feb 5, 2024
1 parent 8ea5ad5 commit 517f2e8
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
2 changes: 1 addition & 1 deletion pyiceberg/io/pyarrow.py
Original file line number Diff line number Diff line change
Expand Up @@ -1775,7 +1775,7 @@ def _get_int(key: str) -> Optional[int]:
if unsupported_keys := fnmatch.filter(table_properties, key_pattern):
raise NotImplementedError(f"Parquet writer option(s) {unsupported_keys} not implemented")

compression_codec = table_properties.get("write.parquet.compression-codec")
compression_codec = table_properties.get("write.parquet.compression-codec", "zstd")
compression_level = _get_int("write.parquet.compression-level")
if compression_codec == "uncompressed":
compression_codec = "none"
Expand Down
3 changes: 0 additions & 3 deletions tests/integration/test_writes.py
Original file line number Diff line number Diff line change
Expand Up @@ -458,7 +458,6 @@ def test_write_parquet_compression_properties(
assert compression == expected_compression_name


@pytest.mark.integration
@pytest.mark.integration
@pytest.mark.parametrize(
"properties, expected_kwargs",
Expand Down Expand Up @@ -487,8 +486,6 @@ def test_write_parquet_other_properties(
assert call_kwargs.get(key) == value


@pytest.mark.integration
@pytest.mark.integration
@pytest.mark.integration
@pytest.mark.parametrize(
"properties",
Expand Down

0 comments on commit 517f2e8

Please sign in to comment.