From 8d02736c6cd5cddc71ce5b62ec0855c11e627a3d Mon Sep 17 00:00:00 2001 From: phi Date: Sun, 28 Jul 2024 04:04:04 +0900 Subject: [PATCH] fix --- src/async_wrapper/queue.py | 2 +- tests/test_pipe.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) 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():