@@ -357,7 +357,7 @@ class ParallelProcessing(Generic[_Target_P, _Target_T, _Dataset_T]):
357357 SupportsLengthGetItem [_Dataset_T ],
358358 SupportsGetItem [_Dataset_T ],
359359 SupportsLength ,
360- type [_Dataset_T ],
360+ Any [_Dataset_T ],
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 : type [_Dataset_T ],
417+ dataset : Any [_Dataset_T ],
418418 max_threads : int = 8 ,
419419 * overflow_args : Overflow_In ,
420- _get_value : Callable [[type [_Dataset_T ], int ], _Dataset_T ],
421- _length : Union [int , Callable [[type [_Dataset_T ]], int ]],
420+ _get_value : Callable [[Any [_Dataset_T ], int ], _Dataset_T ],
421+ _length : Union [int , Callable [[Any [_Dataset_T ]], 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- type [_Dataset_T ],
432+ Any [_Dataset_T ],
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 [[type [_Dataset_T ], int ], _Dataset_T ],
441+ Callable [[Any [_Dataset_T ], int ], _Dataset_T ],
442442 ]
443443 ] = None ,
444444 _length : Optional [
0 commit comments