Skip to content

Commit c799fc9

Browse files
committed
use default formatter first
1 parent 14000dc commit c799fc9

1 file changed

Lines changed: 5 additions & 7 deletions

File tree

pyiceberg/table/update/__init__.py

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
from typing import TYPE_CHECKING, Annotated, Any, Dict, Generic, List, Literal, Optional, Tuple, TypeVar, Union, cast
2525

2626
from pydantic import Field, field_validator, model_validator, model_serializer
27+
from pydantic_core.core_schema import SerializerFunctionWrapHandler, SerializationInfo
2728

2829
from pyiceberg.exceptions import CommitFailedException
2930
from pyiceberg.partitioning import PARTITION_FIELD_ID_START, PartitionSpec
@@ -727,13 +728,10 @@ class AssertRefSnapshotId(ValidatableTableRequirement):
727728
ref: str = Field(...)
728729
snapshot_id: Optional[int] = Field(default=None, alias="snapshot-id")
729730

730-
@model_serializer
731-
def ser_model(self) -> dict[str, Any]:
732-
return {
733-
"type": self.type,
734-
"ref": self.ref,
735-
"snapshot-id": self.snapshot_id,
736-
}
731+
@model_serializer(mode="wrap")
732+
def serialize_model(self, handler) -> dict[str, Any]:
733+
partial_result = handler(self)
734+
return {**partial_result, "snapshot-id": self.snapshot_id}
737735

738736
def validate(self, base_metadata: Optional[TableMetadata]) -> None:
739737
if base_metadata is None:

0 commit comments

Comments
 (0)