Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
phi-friday committed Jul 27, 2024
1 parent 9d74ab8 commit 8d02736
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/async_wrapper/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
6 changes: 3 additions & 3 deletions tests/test_pipe.py
Original file line number Diff line number Diff line change
Expand Up @@ -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():
Expand All @@ -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():
Expand All @@ -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():
Expand Down

0 comments on commit 8d02736

Please sign in to comment.