diff --git a/src/async_wrapper/queue.py b/src/async_wrapper/queue.py index 794f649..021b913 100644 --- a/src/async_wrapper/queue.py +++ b/src/async_wrapper/queue.py @@ -28,7 +28,7 @@ ) if sys.version_info < (3, 11): # pragma: no cover - from exceptiongroup import ExceptionGroup # pyright: ignore[reportMissingImports] + from exceptiongroup import ExceptionGroup if TYPE_CHECKING: from types import TracebackType diff --git a/tests/test_pipe.py b/tests/test_pipe.py index d133ce0..102c34d 100644 --- a/tests/test_pipe.py +++ b/tests/test_pipe.py @@ -416,7 +416,7 @@ async def hit(value: Any, index: int) -> None: await pipe.next(1) q = size // sema_value + 1 - assert EPSILON * q < timer.term < EPSILON * q + EPSILON + assert timer.term < EPSILON * q + EPSILON async def test_pipe_limit(): @@ -438,7 +438,7 @@ async def hit(value: Any, index: int) -> None: await pipe.next(1) q = size // limit_value + 1 - assert EPSILON * q < timer.term < EPSILON * q + EPSILON + assert timer.term < EPSILON * q + EPSILON async def test_pipe_lock(): @@ -458,7 +458,7 @@ async def hit(value: Any, index: int) -> None: with Timer() as timer: await pipe.next(1) - assert EPSILON * size < timer.term < EPSILON * size + EPSILON + assert timer.term < EPSILON * size + EPSILON async def test_pipe_next_after_disposed():