Skip to content

Commit db34450

Browse files
committed
style: make AggregateFnV2 generic over accumulator/result (Generic[AggType, U])
Signed-off-by: Arthur <atte.book@gmail.com>
1 parent 6351471 commit db34450

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/ray/data/aggregate.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import abc
22
import math
3-
from typing import TYPE_CHECKING, Any, Callable, List, Optional
3+
from typing import TYPE_CHECKING, Any, Callable, Generic, List, Optional
44

55
import numpy as np
66
import pyarrow.compute as pc
@@ -113,7 +113,7 @@ def _validate(self, schema: Optional["Schema"]) -> None:
113113

114114

115115
@PublicAPI(stability="alpha")
116-
class AggregateFnV2(AggregateFn, abc.ABC):
116+
class AggregateFnV2(AggregateFn, abc.ABC, Generic[AggType, U]):
117117
"""Provides an interface to implement efficient aggregations to be applied
118118
to the dataset.
119119

0 commit comments

Comments
 (0)