This is an automated email from the ASF dual-hosted git repository.
sungwy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-python.git
The following commit(s) were added to refs/heads/main by this push:
new be5c4264 missing markers (#969)
be5c4264 is described below
commit be5c42649914e71e8366c22558f8234ce062b145
Author: Sung Yun <[email protected]>
AuthorDate: Fri Jul 26 16:44:36 2024 -0400
missing markers (#969)
Co-authored-by: Sung Yun <[email protected]>
---
tests/integration/test_deletes.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/tests/integration/test_deletes.py
b/tests/integration/test_deletes.py
index c474de29..49de265a 100644
--- a/tests/integration/test_deletes.py
+++ b/tests/integration/test_deletes.py
@@ -105,6 +105,7 @@ def test_partitioned_table_rewrite(spark: SparkSession,
session_catalog: RestCat
assert tbl.scan().to_arrow().to_pydict() == {"number_partitioned": [11,
10], "number": [30, 30]}
[email protected]
@pytest.mark.parametrize("format_version", [1, 2])
def test_rewrite_partitioned_table_with_null(spark: SparkSession,
session_catalog: RestCatalog, format_version: int) -> None:
identifier = "default.table_partitioned_delete"
@@ -453,6 +454,7 @@ def test_delete_truncate(session_catalog: RestCatalog) ->
None:
assert entries[0].status == ManifestEntryStatus.DELETED
[email protected]
def test_delete_overwrite_table_with_null(session_catalog: RestCatalog) ->
None:
arrow_schema = pa.schema([pa.field("ints", pa.int32())])
arrow_tbl = pa.Table.from_pylist(
@@ -492,6 +494,7 @@ def test_delete_overwrite_table_with_null(session_catalog:
RestCatalog) -> None:
assert tbl.scan().to_arrow()["ints"].to_pylist() == [3, 4, 1, None]
[email protected]
def test_delete_overwrite_table_with_nan(session_catalog: RestCatalog) -> None:
arrow_schema = pa.schema([pa.field("floats", pa.float32())])
