@@ -147,7 +147,6 @@ def __init__(
147147 chunk : str | FuncTuple | None ,
148148 combine : str | FuncTuple | None ,
149149 preprocess : Callable | None = None ,
150- aggregate : Callable | None = None ,
151150 finalize : Callable | None = None ,
152151 fill_value = None ,
153152 final_fill_value = dtypes .NA ,
@@ -209,8 +208,6 @@ def __init__(
209208 self .combine : FuncTuple = _atleast_1d (combine )
210209 # simpler reductions used with the "simple combine" algorithm
211210 self .simple_combine : tuple [Callable , ...] = ()
212- # final aggregation
213- self .aggregate : Callable | str = aggregate if aggregate else self .combine [0 ]
214211 # finalize results (see mean)
215212 self .finalize : Callable | None = finalize
216213
@@ -249,7 +246,6 @@ def __dask_tokenize__(self):
249246 self .numpy ,
250247 self .chunk ,
251248 self .combine ,
252- self .aggregate ,
253249 self .finalize ,
254250 self .fill_value ,
255251 self .dtype ,
@@ -261,7 +257,6 @@ def __repr__(self) -> str:
261257 f"{ self .name !r} , fill: { self .fill_value .values ()!r} , dtype: { self .dtype } " ,
262258 f"chunk: { self .chunk !r} " ,
263259 f"combine: { self .combine !r} " ,
264- f"aggregate: { self .aggregate !r} " ,
265260 f"finalize: { self .finalize !r} " ,
266261 f"min_count: { self .min_count !r} " ,
267262 )
0 commit comments