Skip to content

Commit cfe14a4

Browse files
committed
Fix concurrent.interpreters.Queue interface for Python 3.14
1 parent 617f423 commit cfe14a4

File tree

1 file changed

+25
-9
lines changed

1 file changed

+25
-9
lines changed

stdlib/concurrent/interpreters/_queues.pyi

Lines changed: 25 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
import queue
2+
from re import S
23
import sys
34
from typing import Final, SupportsIndex
45
from typing_extensions import Self
@@ -45,14 +46,29 @@ if sys.version_info >= (3, 13): # needed to satisfy pyright checks for Python <
4546
def empty(self) -> bool: ...
4647
def full(self) -> bool: ...
4748
def qsize(self) -> int: ...
48-
def put(
49-
self,
50-
obj: object,
51-
timeout: SupportsIndex | None = None,
52-
*,
53-
unbounditems: _AnyUnbound | None = None,
54-
_delay: float = 0.01,
55-
) -> None: ...
49+
if sys.version_info >= (3, 14):
50+
def put(
51+
self,
52+
obj: object,
53+
block: bool = True,
54+
timeout: SupportsIndex | None = None,
55+
*,
56+
unbounditems: _AnyUnbound | None = None,
57+
_delay: float = 0.01,
58+
) -> None: ...
59+
else:
60+
def put(
61+
self,
62+
obj: object,
63+
timeout: SupportsIndex | None = None,
64+
*,
65+
unbounditems: _AnyUnbound | None = None,
66+
_delay: float = 0.01,
67+
) -> None: ...
5668
def put_nowait(self, obj: object, *, unbounditems: _AnyUnbound | None = None) -> None: ...
57-
def get(self, timeout: SupportsIndex | None = None, *, _delay: float = 0.01) -> object: ...
69+
if sys.version_info >= (3, 14):
70+
def get(self, block: bool = True, timeout: SupportsIndex | None = None, *, _delay: float = 0.01) -> object: ...
71+
else:
72+
def get(self, timeout: SupportsIndex | None = None, *, _delay: float = 0.01) -> object: ...
73+
5874
def get_nowait(self) -> object: ...

0 commit comments

Comments
 (0)