Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
Fokko committed Jan 21, 2025
1 parent cafd39d commit 9bf6cda
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions pyiceberg/partitioning.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
Optional,
Tuple,
TypeVar,
Union,
)
from urllib.parse import quote_plus

Expand Down Expand Up @@ -416,8 +415,8 @@ def partition_record_value(partition_field: PartitionField, value: Any, schema:
iceberg_type = schema.find_field(name_or_id=partition_field.source_id).field_type
if not isinstance(value, int):
# When adding files, it can be that we still need to convert from logical types to physical types
iceberg_typed_value = _to_partition_representation(iceberg_type, value)
transformed_value = partition_field.transform.transform(iceberg_type)(iceberg_typed_value)
value = _to_partition_representation(iceberg_type, value)
transformed_value = partition_field.transform.transform(iceberg_type)(value)
return transformed_value


Expand Down

0 comments on commit 9bf6cda

Please sign in to comment.