diff --git a/pyiceberg/table/__init__.py b/pyiceberg/table/__init__.py index e6c8efd98d..1e81357367 100644 --- a/pyiceberg/table/__init__.py +++ b/pyiceberg/table/__init__.py @@ -1127,7 +1127,7 @@ def append(self, df: pa.Table, snapshot_properties: Dict[str, str] = EMPTY_DICT) raise ValueError("Cannot write to partitioned tables") _check_schema_compatible(self.schema(), other_schema=df.schema) - # safe to cast + # the two schemas are compatible so safe to cast df = df.cast(self.schema().as_arrow()) with self.transaction() as txn: @@ -1167,7 +1167,7 @@ def overwrite( raise ValueError("Cannot write to partitioned tables") _check_schema_compatible(self.schema(), other_schema=df.schema) - # safe to cast + # the two schemas are compatible so safe to cast df = df.cast(self.schema().as_arrow()) with self.transaction() as txn: