@@ -357,7 +357,7 @@ class ParallelProcessing(Generic[_Target_P, _Target_T, _Dataset_T]):
357357 SupportsLengthGetItem [_Dataset_T ],
358358 SupportsGetItem [_Dataset_T ],
359359 SupportsLength ,
360- Any [ _Dataset_T ] ,
360+ Any ,
361361 ]
362362 max_threads : int
363363
@@ -414,11 +414,11 @@ def __init__(
414414 def __init__ (
415415 self ,
416416 function : DatasetFunction [_Dataset_T , _Target_P , _Target_T ],
417- dataset : Any [ _Dataset_T ] ,
417+ dataset : Any ,
418418 max_threads : int = 8 ,
419419 * overflow_args : Overflow_In ,
420- _get_value : Callable [[Any [ _Dataset_T ] , int ], _Dataset_T ],
421- _length : Union [int , Callable [[Any [ _Dataset_T ] ], int ]],
420+ _get_value : Callable [[Any , int ], _Dataset_T ],
421+ _length : Union [int , Callable [[Any ], int ]],
422422 ** overflow_kwargs : Overflow_In ,
423423 ) -> None : ...
424424
@@ -429,7 +429,7 @@ def __init__(
429429 SupportsLengthGetItem [_Dataset_T ],
430430 SupportsGetItem [_Dataset_T ],
431431 SupportsLength ,
432- Any [ _Dataset_T ] ,
432+ Any ,
433433 ],
434434 max_threads : int = 8 ,
435435 * overflow_args : Overflow_In ,
@@ -438,7 +438,7 @@ def __init__(
438438 Callable [[SupportsLengthGetItem [_Dataset_T ], int ], _Dataset_T ],
439439 Callable [[SupportsGetItem [_Dataset_T ], int ], _Dataset_T ],
440440 Callable [[SupportsLength , int ], _Dataset_T ],
441- Callable [[Any [ _Dataset_T ] , int ], _Dataset_T ],
441+ Callable [[Any , int ], _Dataset_T ],
442442 ]
443443 ] = None ,
444444 _length : Optional [
0 commit comments