Skip to content

Commit d4702a4

Browse files
committed
Cleanup
1 parent edbac4d commit d4702a4

File tree

2 files changed

+1
-25
lines changed

2 files changed

+1
-25
lines changed

pyiceberg/transforms.py

Lines changed: 0 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -111,29 +111,6 @@ def _transform_literal(func: Callable[[L], L], lit: Literal[L]) -> Literal[L]:
111111
return literal(func(lit.value))
112112

113113

114-
def parse_transform(v: Any) -> Any:
115-
if isinstance(v, str):
116-
if v == IDENTITY:
117-
return IdentityTransform()
118-
elif v == VOID:
119-
return VoidTransform()
120-
elif v.startswith(BUCKET):
121-
return BucketTransform(num_buckets=BUCKET_PARSER.match(v))
122-
elif v.startswith(TRUNCATE):
123-
return TruncateTransform(width=TRUNCATE_PARSER.match(v))
124-
elif v == YEAR:
125-
return YearTransform()
126-
elif v == MONTH:
127-
return MonthTransform()
128-
elif v == DAY:
129-
return DayTransform()
130-
elif v == HOUR:
131-
return HourTransform()
132-
else:
133-
return UnknownTransform(transform=v)
134-
return v
135-
136-
137114
def _pyiceberg_transform_wrapper(
138115
transform_func: Callable[["ArrayLike", Any], "ArrayLike"],
139116
*args: Any,

tests/test_transforms.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,15 +16,14 @@
1616
# specific language governing permissions and limitations
1717
# under the License.
1818
# pylint: disable=eval-used,protected-access,redefined-outer-name
19-
from datetime import date, datetime
19+
from datetime import date
2020
from decimal import Decimal
2121
from typing import Annotated, Any, Callable, Optional, Union
2222
from uuid import UUID
2323

2424
import mmh3 as mmh3
2525
import pyarrow as pa
2626
import pytest
27-
import pytz
2827
from pydantic import (
2928
BeforeValidator,
3029
PlainSerializer,

0 commit comments

Comments
 (0)