syun64 commented on code in PR #728:
URL: https://github.com/apache/iceberg-python/pull/728#discussion_r1632294680
##########
pyiceberg/table/__init__.py:
##########
@@ -340,6 +340,34 @@ def set_properties(self, properties: Properties =
EMPTY_DICT, **kwargs: Any) ->
updates = properties or kwargs
return self._apply((SetPropertiesUpdate(updates=updates),))
+ def set_ref_snapshot(
+ self,
+ snapshot_id: int,
+ parent_snapshot_id: Optional[int],
+ ref_name: str,
+ type: str,
+ max_age_ref_ms: Optional[int] = None,
+ max_snapshot_age_ms: Optional[int] = None,
+ min_snapshots_to_keep: Optional[int] = None,
+ ) -> Transaction:
+ """Update a ref to a snapshot.
+
+ Returns:
+ The transaction with the set-snapshot-ref staged
+ """
+ updates = SetSnapshotRefUpdate(
+ snapshot_id=snapshot_id,
+ parent_snapshot_id=parent_snapshot_id,
+ ref_name=ref_name,
+ type=type,
+ max_age_ref_ms=max_age_ref_ms,
+ max_snapshot_age_ms=max_snapshot_age_ms,
+ min_snapshots_to_keep=min_snapshots_to_keep,
+ )
+
+ requirements = AssertRefSnapshotId(snapshot_id=parent_snapshot_id,
ref="main")
Review Comment:
Hi @Fokko - wouldn't we always want AssertTableUUID for this operation? When
we manage snapshots on a specific table, I think we always intend to add a
snapshot ID or update the snapshot ID of a ref branch (main, etc) based on the
specific instance of the table the client is aware of (which is tracked by the
table UUID).
I think adding AssertTableUUID will prevent the operation from succeeding
when there are concurrent table drop/create operations that could put the table
in a bad state -> https://github.com/apache/iceberg/pull/4322
I'm actually curious why this requirement is missing in the Java
implementation... Is it possible that it's being injected for any `SIMPLE`
TableUpdate types, including snapshot updates?
[UpdateRequirements.java:
forUpdateTable](https://github.com/apache/iceberg/blob/c7de6cb345995cb47312edbef6edae2f17fb8aba/core/src/main/java/org/apache/iceberg/UpdateRequirements.java#L50)
[RESTTableOperations.java: SIMPLE type
commit](https://github.com/apache/iceberg/blob/c7de6cb345995cb47312edbef6edae2f17fb8aba/core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java#L137)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
