Skip to content

Commit 8a64fdb

Browse files
Fix test randomly failing (#81)
1 parent 4244942 commit 8a64fdb

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

tests/test_sync_client.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import asyncio
22
import threading
3+
from asyncio import Event
34
from collections.abc import AsyncIterator
45

56
import grpc
@@ -35,11 +36,14 @@ async def get_stream_stream(self, messages: "AsyncIterator[Request]") -> "AsyncI
3536

3637
@pytest.mark.asyncio
3738
async def test_sync_client():
39+
# The event will be set to close the server
40+
close_server_event = Event()
41+
3842
def start_server():
3943
async def run_server():
4044
server = Server([SimpleService()])
4145
await server.start("127.0.0.1", 1234)
42-
await asyncio.sleep(3) # Close the server after 3 seconds
46+
await close_server_event.wait()
4347
server.close()
4448

4549
loop = asyncio.new_event_loop()
@@ -66,6 +70,8 @@ async def run_server():
6670
response = client.get_stream_stream([Request(value=i) for i in range(5)])
6771
assert [r.message for r in response] == [f"Hello {i}" for i in range(5)]
6872

73+
close_server_event.set()
74+
6975
# Create an async client
7076
# client = SimpleServiceStub(Channel(host="127.0.0.1", port=1234))
7177
# response = await client.get_unary_unary(Request(value=42))

0 commit comments

Comments
 (0)