@@ -1654,38 +1654,6 @@ def test_bucket_pyarrow_transforms(
16541654 assert expected == transform .pyarrow_transform (source_type )(input_arr )
16551655
16561656
1657- # pyiceberg_core currently does not support bucket transform on timestamp_ns and timestamptz_ns
1658- # https://github.com/apache/iceberg-rust/issues/1110
1659- @pytest .mark .parametrize (
1660- "source_type, input_arr, num_buckets" ,
1661- [
1662- (
1663- TimestampNanoType (),
1664- pa .array ([datetime (1970 , 1 , 1 , 0 , 0 , 0 ), datetime (2025 , 2 , 26 , 1 , 2 , 3 )], type = pa .timestamp (unit = "ns" )),
1665- 10 ,
1666- ),
1667- (
1668- TimestamptzNanoType (),
1669- pa .array (
1670- [datetime (1970 , 1 , 1 , 0 , 0 , 0 ), datetime (2025 , 2 , 26 , 1 , 2 , 3 )],
1671- type = pa .timestamp (unit = "ns" , tz = pytz .timezone ("Etc/GMT+10" )),
1672- ),
1673- 10 ,
1674- ),
1675- ],
1676- )
1677- def test_unsupported_bucket_pyarrow_transform (
1678- source_type : PrimitiveType ,
1679- input_arr : Union [pa .Array , pa .ChunkedArray ],
1680- num_buckets : int ,
1681- ) -> None :
1682- transform : Transform [Any , Any ] = BucketTransform (num_buckets = num_buckets )
1683- with pytest .raises (ValueError ) as exc_info :
1684- transform .pyarrow_transform (source_type )(input_arr )
1685-
1686- assert "FeatureUnsupported => Unsupported data type for bucket transform" in str (exc_info .value )
1687-
1688-
16891657@pytest .mark .parametrize (
16901658 "source_type, input_arr, expected, width" ,
16911659 [
0 commit comments