mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

fix(pytest): Fix renamed flag (#2197)

Browse source 
Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>
This commit is contained in:
Vladislav 2023-11-20 23:54:11 +03:00 committed by GitHub
parent d21f82a5f9
commit 604c600166
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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/dragonfly/connection_test.py
View file

@ -295,7 +295,7 @@ will eventually unblock when it disconnects.
@pytest.mark.asyncio
@pytest.mark.slow
@dfly_args({"proactor_threads": "1", "pipeline_queue_limit": "100"})
@dfly_args({"proactor_threads": "1", "subscriber_thread_limit": "100"})
async def test_publish_stuck(df_server: DflyInstance, async_client: aioredis.Redis):
reader, writer = await asyncio.open_connection("127.0.0.1", df_server.port, limit=10)
writer.write(b"SUBSCRIBE channel\r\n")
@ -313,13 +313,13 @@ async def test_publish_stuck(df_server: DflyInstance, async_client: aioredis.Red
await asyncio.sleep(5)
# Check we reached the limit
pub_bytes = int((await async_client.info())["dispatch_queue_pub_bytes"])
pub_bytes = int((await async_client.info())["dispatch_queue_subscriber_bytes"])
assert pub_bytes >= 100
await asyncio.sleep(0.1)
# Make sure processing is stalled
new_pub_bytes = int((await async_client.info())["dispatch_queue_pub_bytes"])
new_pub_bytes = int((await async_client.info())["dispatch_queue_subscriber_bytes"])
assert new_pub_bytes == pub_bytes
writer.write(b"QUIT\r\n")