Fix incorrect typehint for callbacks in multiprocessing.Pool (#10949)

This commit is contained in:
Serious-senpai
2023-11-02 22:59:29 +07:00
committed by GitHub
parent b3fa05ae31
commit fa088948aa

View File

@@ -91,7 +91,7 @@ class Pool:
func: Callable[[_S], _T],
iterable: Iterable[_S],
chunksize: int | None = None,
callback: Callable[[_T], object] | None = None,
callback: Callable[[list[_T]], object] | None = None,
error_callback: Callable[[BaseException], object] | None = None,
) -> MapResult[_T]: ...
def imap(self, func: Callable[[_S], _T], iterable: Iterable[_S], chunksize: int | None = 1) -> IMapIterator[_T]: ...
@@ -102,7 +102,7 @@ class Pool:
func: Callable[..., _T],
iterable: Iterable[Iterable[Any]],
chunksize: int | None = None,
callback: Callable[[_T], object] | None = None,
callback: Callable[[list[_T]], object] | None = None,
error_callback: Callable[[BaseException], object] | None = None,
) -> AsyncResult[list[_T]]: ...
def close(self) -> None: ...