@@ -147,7 +147,6 @@ def __init__(
147
147
chunk : str | FuncTuple | None ,
148
148
combine : str | FuncTuple | None ,
149
149
preprocess : Callable | None = None ,
150
- aggregate : Callable | None = None ,
151
150
finalize : Callable | None = None ,
152
151
fill_value = None ,
153
152
final_fill_value = dtypes .NA ,
@@ -209,8 +208,6 @@ def __init__(
209
208
self .combine : FuncTuple = _atleast_1d (combine )
210
209
# simpler reductions used with the "simple combine" algorithm
211
210
self .simple_combine : tuple [Callable , ...] = ()
212
- # final aggregation
213
- self .aggregate : Callable | str = aggregate if aggregate else self .combine [0 ]
214
211
# finalize results (see mean)
215
212
self .finalize : Callable | None = finalize
216
213
@@ -249,7 +246,6 @@ def __dask_tokenize__(self):
249
246
self .numpy ,
250
247
self .chunk ,
251
248
self .combine ,
252
- self .aggregate ,
253
249
self .finalize ,
254
250
self .fill_value ,
255
251
self .dtype ,
@@ -261,7 +257,6 @@ def __repr__(self) -> str:
261
257
f"{ self .name !r} , fill: { self .fill_value .values ()!r} , dtype: { self .dtype } " ,
262
258
f"chunk: { self .chunk !r} " ,
263
259
f"combine: { self .combine !r} " ,
264
- f"aggregate: { self .aggregate !r} " ,
265
260
f"finalize: { self .finalize !r} " ,
266
261
f"min_count: { self .min_count !r} " ,
267
262
)
0 commit comments