adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix OOM on emc test

Browse Source
This commit is contained in:
Timothy Pogue 2022-09-13 13:36:21 -06:00
parent 877d24bcdd
commit 46a425d1b6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/rpc/test_rpc_emc.py
View File

@ -184,14 +184,14 @@ async def test_emc_create_connection_success(default_conf, caplog, mocker):
test_producer = default_conf['external_message_consumer']['producers'][0] test_producer = default_conf['external_message_consumer']['producers'][0]
lock = asyncio.Lock() lock = asyncio.Lock()
emc._running = True
async def eat(websocket): async def eat(websocket):
pass emc._running = False
try: try:
async with websockets.serve(eat, _TEST_WS_HOST, _TEST_WS_PORT): async with websockets.serve(eat, _TEST_WS_HOST, _TEST_WS_PORT):
emc._running = True
await emc._create_connection(test_producer, lock) await emc._create_connection(test_producer, lock)
emc._running = False
assert log_has_re(r"Producer connection success.+", caplog) assert log_has_re(r"Producer connection success.+", caplog)
finally: finally: