We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 12d978e commit 336dcf8Copy full SHA for 336dcf8
1 file changed
pyiceberg/table/__init__.py
@@ -823,6 +823,7 @@ def upsert(
823
f"Extension type '{arr.type}' for column '{col}' is not currently supported as a join key in upsert."
824
)
825
826
+ # Validate uniqueness after type checks to avoid comparing/hashing unsupported types.
827
if upsert_util.has_duplicate_rows(df, join_cols):
828
raise ValueError("Duplicate rows found in source dataset based on the key columns. No upsert executed")
829
0 commit comments