multiprocessing: add shutdown_timeout param to BaseManager (#7692)

JelleZijlstra · web-flow · commit 573539ba2ae8 · 2022-04-25T22:12:56.000-06:00
python/cpython#32112
diff --git a/stdlib/multiprocessing/managers.pyi b/stdlib/multiprocessing/managers.pyi
@@ -76,9 +76,21 @@ class Server:
     def accept_connection(self, c: Connection, name: str) -> None: ...
 
 class BaseManager:
-    def __init__(
-        self, address: Any | None = ..., authkey: bytes | None = ..., serializer: str = ..., ctx: BaseContext | None = ...
-    ) -> None: ...
+    if sys.version_info >= (3, 11):
+        def __init__(
+            self,
+            address: Any | None = ...,
+            authkey: bytes | None = ...,
+            serializer: str = ...,
+            ctx: BaseContext | None = ...,
+            *,
+            shutdown_timeout: float = ...,
+        ) -> None: ...
+    else:
+        def __init__(
+            self, address: Any | None = ..., authkey: bytes | None = ..., serializer: str = ..., ctx: BaseContext | None = ...
+        ) -> None: ...
+
     def get_server(self) -> Server: ...
     def connect(self) -> None: ...
     def start(self, initializer: Callable[..., Any] | None = ..., initargs: Iterable[Any] = ...) -> None: ...
