order

kevinjqliu · kevinjqliu · commit 93de31969534 · 2025-03-29T20:10:33.000-07:00
diff --git a/pyiceberg/table/upsert_util.py b/pyiceberg/table/upsert_util.py
@@ -69,8 +69,8 @@ def get_rows_to_update(source_table: pa.Table, target_table: pa.Table, join_cols
         operator.or_,
         [
             pc.or_kleene(
-                pc.is_null(pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs"))),
                 pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs")),
+                pc.is_null(pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs"))),
             )
             for col in non_key_cols
         ],

Original file line number	Diff line number	Diff line change
`@@ -69,8 +69,8 @@ def get_rows_to_update(source_table: pa.Table, target_table: pa.Table, join_cols`
`69`	`69`	`operator.or_,`
`70`	`70`	`[`
`71`	`71`	`pc.or_kleene(`
`72`		`- pc.is_null(pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs"))),`
`73`	`72`	`pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs")),`
	`73`	`+ pc.is_null(pc.not_equal(pc.field(f"{col}-lhs"), pc.field(f"{col}-rhs"))),`
`74`	`74`	`)`
`75`	`75`	`for col in non_key_cols`
`76`	`76`	`],`