Skip to content

Commit

Permalink
fix types
Browse files Browse the repository at this point in the history
  • Loading branch information
nekufa committed Sep 15, 2023
1 parent 77bcc53 commit 18a6acd
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions tests/test_performance.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ async def test_performance() -> None:
await worker.loop(requests-1)

for thread in range(1, threads):
pipe = Tube(DummyRequest, Route(thread)).pipe
pipe = Tube(DummyHandler, Route(thread)).pipe
assert await queue.storage.length(pipe) == 0

await queue.register(
Expand All @@ -65,7 +65,7 @@ async def test_performance() -> None:
async with measure('worker threads'):
await gather(*[
Worker(RuntimeLock(), queue).loop(
(requests-1/threads) - 1
int(requests-1/threads) - 1
)
])

Expand Down

0 comments on commit 18a6acd

Please sign in to comment.