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

regression: skip client pause test utill we fix the bug (#2177)

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adiholden 2023-11-15 16:31:45 +02:00 committed by GitHub
parent 764d542d42
commit b61d07d2c1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
tests/dragonfly/replication_test.py
View file

@ -1764,6 +1764,7 @@ async def test_search(df_local_factory):
# @pytest.mark.slow
@pytest.mark.skip(reason="Client pause command bug with pipeline squashing")
@pytest.mark.asyncio
async def test_client_pause_with_replica(df_local_factory, df_seeder_factory):
master = df_local_factory.create(proactor_threads=4)
@ -1785,13 +1786,12 @@ async def test_client_pause_with_replica(df_local_factory, df_seeder_factory):
# block the seeder for 4 seconds
await c_master.execute_command("client pause 4000 write")
stats = await c_master.info("CommandStats")
info = await c_master.info("Stats")
await asyncio.sleep(0.5)
stats_after_sleep = await c_master.info("CommandStats")
# Check no commands are executed except info and replconf called from replica
for cmd, cmd_stats in stats_after_sleep.items():
if "cmdstat_INFO" != cmd and "cmdstat_REPLCONF" != cmd_stats:
assert stats[cmd] == cmd_stats
assert stats[cmd] == cmd_stats, cmd
await asyncio.sleep(6)
seeder.stop()