You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by fo...@apache.org on 2025/02/21 16:15:26 UTC
(iceberg-python) 01/01: Linterrr
This is an automated email from the ASF dual-hosted git repository.
fokko pushed a commit to branch fd-join
in repository https://gitbox.apache.org/repos/asf/iceberg-python.git
commit 8326db4a3aa5c91897475ffdab4ac94ef14dba94
Author: Fokko <fo...@apache.org>
AuthorDate: Fri Feb 21 17:15:08 2025 +0100
Linterrr
---
pyiceberg/table/upsert_util.py | 1 -
tests/table/test_upsert.py | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/pyiceberg/table/upsert_util.py b/pyiceberg/table/upsert_util.py
index 5280a33f..616fd592 100644
--- a/pyiceberg/table/upsert_util.py
+++ b/pyiceberg/table/upsert_util.py
@@ -82,4 +82,3 @@ def get_rows_to_update(source_table: pa.Table, target_table: pa.Table, join_cols
# Finally cast to the original schema since it doesn't carry nullability:
# https://github.com/apache/arrow/issues/45557
).cast(target_table.schema)
-
diff --git a/tests/table/test_upsert.py b/tests/table/test_upsert.py
index 14ab6ff0..dfc00436 100644
--- a/tests/table/test_upsert.py
+++ b/tests/table/test_upsert.py
@@ -389,6 +389,7 @@ def test_create_match_filter_single_condition() -> None:
EqualTo(term=Reference(name="order_line_id"), literal=LongLiteral(1)),
)
+
def test_upsert_with_duplicate_rows_in_table(catalog: Catalog) -> None:
identifier = "default.test_upsert_with_duplicate_rows_in_table"
_drop_table(catalog, identifier)
@@ -429,4 +430,3 @@ def test_upsert_with_duplicate_rows_in_table(catalog: Catalog) -> None:
with pytest.raises(ValueError, match="Target table has duplicate rows, aborting upsert"):
_ = tbl.upsert(df)
-