wip

Yingjian Wu · Yingjian Wu · commit 9bec1653d50e · 2025-08-24T11:05:33.000-07:00
diff --git a/pyiceberg/table/__init__.py b/pyiceberg/table/__init__.py
@@ -807,7 +807,7 @@ def upsert(
             case_sensitive=case_sensitive,
         )
 
-        if branch is not None:
+        if branch in self.table_metadata.refs:
             matched_iceberg_record_batches_scan = matched_iceberg_record_batches_scan.use_ref(branch)
 
         matched_iceberg_record_batches = matched_iceberg_record_batches_scan.to_arrow_batch_reader()

Original file line number	Diff line number	Diff line change
`@@ -807,7 +807,7 @@ def upsert(`
`807`	`807`	`case_sensitive=case_sensitive,`
`808`	`808`	`)`
`809`	`809`
`810`		`- if branch is not None:`
	`810`	`+ if branch in self.table_metadata.refs:`
`811`	`811`	`matched_iceberg_record_batches_scan = matched_iceberg_record_batches_scan.use_ref(branch)`
`812`	`812`
`813`	`813`	`matched_iceberg_record_batches = matched_iceberg_record_batches_scan.to_arrow_batch_reader()`