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)
-