diff --git a/stubs/futures/@python2/concurrent/__init__.pyi b/stubs/futures/@python2/concurrent/__init__.pyi deleted file mode 100644 index e69de29bb..000000000 diff --git a/stubs/futures/@python2/concurrent/futures/__init__.pyi b/stubs/futures/@python2/concurrent/futures/__init__.pyi deleted file mode 100644 index 1f93f021f..000000000 --- a/stubs/futures/@python2/concurrent/futures/__init__.pyi +++ /dev/null @@ -1,13 +0,0 @@ -from ._base import ( - ALL_COMPLETED as ALL_COMPLETED, - FIRST_COMPLETED as FIRST_COMPLETED, - FIRST_EXCEPTION as FIRST_EXCEPTION, - CancelledError as CancelledError, - Executor as Executor, - Future as Future, - TimeoutError as TimeoutError, - as_completed as as_completed, - wait as wait, -) -from .process import ProcessPoolExecutor as ProcessPoolExecutor -from .thread import ThreadPoolExecutor as ThreadPoolExecutor diff --git a/stubs/futures/@python2/concurrent/futures/_base.pyi b/stubs/futures/@python2/concurrent/futures/_base.pyi deleted file mode 100644 index 23edd20a9..000000000 --- a/stubs/futures/@python2/concurrent/futures/_base.pyi +++ /dev/null @@ -1,94 +0,0 @@ -import threading -from _typeshed import Self -from abc import abstractmethod -from logging import Logger -from types import TracebackType -from typing import Any, Callable, Container, Generic, Iterable, Iterator, Optional, Protocol, TypeVar -from typing_extensions import ParamSpec - -FIRST_COMPLETED: str -FIRST_EXCEPTION: str -ALL_COMPLETED: str -PENDING: str -RUNNING: str -CANCELLED: str -CANCELLED_AND_NOTIFIED: str -FINISHED: str -LOGGER: Logger - -class Error(Exception): ... -class CancelledError(Error): ... -class TimeoutError(Error): ... - -_T = TypeVar("_T") -_T_co = TypeVar("_T_co", covariant=True) -_P = ParamSpec("_P") - -# Copied over Collection implementation as it does not exist in Python 2 and <3.6. -# Also to solve pytype issues with _Collection. -class _Collection(Iterable[_T_co], Container[_T_co], Protocol[_T_co]): - # Implement Sized (but don't have it as a base class). - @abstractmethod - def __len__(self) -> int: ... - -class Future(Generic[_T]): - def __init__(self) -> None: ... - def cancel(self) -> bool: ... - def cancelled(self) -> bool: ... - def running(self) -> bool: ... - def done(self) -> bool: ... - def add_done_callback(self, fn: Callable[[Future[_T]], Any]) -> None: ... - def result(self, timeout: Optional[float] = ...) -> _T: ... - def set_running_or_notify_cancel(self) -> bool: ... - def set_result(self, result: _T) -> None: ... - def exception(self, timeout: Optional[float] = ...) -> Any: ... - def exception_info(self, timeout: Optional[float] = ...) -> tuple[Any, Optional[TracebackType]]: ... - def set_exception(self, exception: Any) -> None: ... - def set_exception_info(self, exception: Any, traceback: Optional[TracebackType]) -> None: ... - -class Executor: - def submit(self, fn: Callable[_P, _T], *args: _P.args, **kwargs: _P.kwargs) -> Future[_T]: ... - def map(self, func: Callable[..., _T], *iterables: Iterable[Any], timeout: Optional[float] = ...) -> Iterator[_T]: ... - def shutdown(self, wait: bool = ...) -> None: ... - def __enter__(self: Self) -> Self: ... - def __exit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> Optional[bool]: ... - -def as_completed(fs: Iterable[Future[_T]], timeout: Optional[float] = ...) -> Iterator[Future[_T]]: ... -def wait( - fs: _Collection[Future[_T]], timeout: Optional[float] = ..., return_when: str = ... -) -> tuple[set[Future[_T]], set[Future[_T]]]: ... - -class _Waiter: - event: threading.Event - finished_futures: list[Future[Any]] - def __init__(self) -> None: ... - def add_result(self, future: Future[Any]) -> None: ... - def add_exception(self, future: Future[Any]) -> None: ... - def add_cancelled(self, future: Future[Any]) -> None: ... - -class _AsCompletedWaiter(_Waiter): - lock: threading.Lock - def __init__(self) -> None: ... - def add_result(self, future: Future[Any]) -> None: ... - def add_exception(self, future: Future[Any]) -> None: ... - def add_cancelled(self, future: Future[Any]) -> None: ... - -class _FirstCompletedWaiter(_Waiter): - def add_result(self, future: Future[Any]) -> None: ... - def add_exception(self, future: Future[Any]) -> None: ... - def add_cancelled(self, future: Future[Any]) -> None: ... - -class _AllCompletedWaiter(_Waiter): - num_pending_calls: int - stop_on_exception: bool - lock: threading.Lock - def __init__(self, num_pending_calls: int, stop_on_exception: bool) -> None: ... - def add_result(self, future: Future[Any]) -> None: ... - def add_exception(self, future: Future[Any]) -> None: ... - def add_cancelled(self, future: Future[Any]) -> None: ... - -class _AcquireFutures: - futures: Iterable[Future[Any]] - def __init__(self, futures: Iterable[Future[Any]]) -> None: ... - def __enter__(self) -> None: ... - def __exit__(self, *args: Any) -> None: ... diff --git a/stubs/futures/@python2/concurrent/futures/process.pyi b/stubs/futures/@python2/concurrent/futures/process.pyi deleted file mode 100644 index d56902c48..000000000 --- a/stubs/futures/@python2/concurrent/futures/process.pyi +++ /dev/null @@ -1,8 +0,0 @@ -from typing import Any, Optional - -from ._base import Executor - -EXTRA_QUEUED_CALLS: Any - -class ProcessPoolExecutor(Executor): - def __init__(self, max_workers: Optional[int] = ...) -> None: ... diff --git a/stubs/futures/@python2/concurrent/futures/thread.pyi b/stubs/futures/@python2/concurrent/futures/thread.pyi deleted file mode 100644 index 6e272f38d..000000000 --- a/stubs/futures/@python2/concurrent/futures/thread.pyi +++ /dev/null @@ -1,16 +0,0 @@ -from typing import Any, Callable, Generic, Iterable, Mapping, Optional, TypeVar - -from ._base import Executor, Future - -_S = TypeVar("_S") - -class ThreadPoolExecutor(Executor): - def __init__(self, max_workers: Optional[int] = ..., thread_name_prefix: str = ...) -> None: ... - -class _WorkItem(Generic[_S]): - future: Future[_S] - fn: Callable[..., _S] - args: Iterable[Any] - kwargs: Mapping[str, Any] - def __init__(self, future: Future[_S], fn: Callable[..., _S], args: Iterable[Any], kwargs: Mapping[str, Any]) -> None: ... - def run(self) -> None: ... diff --git a/stubs/futures/METADATA.toml b/stubs/futures/METADATA.toml deleted file mode 100644 index 103ece479..000000000 --- a/stubs/futures/METADATA.toml +++ /dev/null @@ -1,2 +0,0 @@ -version = "3.3.*" -python2 = true diff --git a/stubs/protobuf/METADATA.toml b/stubs/protobuf/METADATA.toml index 808e95a45..5004c7555 100644 --- a/stubs/protobuf/METADATA.toml +++ b/stubs/protobuf/METADATA.toml @@ -1,4 +1,2 @@ version = "3.19.*" -python2 = true -requires = ["types-futures"] extra_description = "Generated with aid from mypy-protobuf v3.2.0"