mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix: cluster tests stability (#4338)

Browse source
This commit is contained in:
Borys 2024-12-18 15:43:45 +02:00 • committed by GitHub
parent 32d71071ae
commit 6a7931985b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
tests/dragonfly/cluster_test.py
View file

@ -920,7 +920,7 @@ async def test_cluster_flush_slots_after_config_change(df_factory: DflyInstanceF
assert await c_replica.execute_command("dbsize") == (100_000 - slot_0_size)
@dfly_args({"proactor_threads": 4, "cluster_mode": "yes", "admin_port": 30001})
@dfly_args({"proactor_threads": 4, "cluster_mode": "yes", "admin_port": next(next_port)})
async def test_cluster_blocking_command(df_server):
c_master = df_server.client()
c_master_admin = df_server.admin_client()
@ -1451,7 +1451,7 @@ async def test_network_disconnect_during_migration(df_factory):
await StaticSeeder(key_target=100000).run(nodes[0].client)
start_capture = await StaticSeeder.capture(nodes[0].client)
proxy = Proxy("127.0.0.1", 1111, "127.0.0.1", nodes[1].instance.admin_port)
proxy = Proxy("127.0.0.1", next(next_port), "127.0.0.1", nodes[1].instance.admin_port)
await proxy.start()
task = asyncio.create_task(proxy.serve())
@ -2163,7 +2163,7 @@ async def test_replicate_disconnect_cluster(df_factory: DflyInstanceFactory, df_
fill_task = asyncio.create_task(seeder.run())
proxy = Proxy("127.0.0.1", 1114, "127.0.0.1", cluster_nodes[0].port)
proxy = Proxy("127.0.0.1", next(next_port), "127.0.0.1", cluster_nodes[0].port)
await proxy.start()
proxy_task = asyncio.create_task(proxy.serve())
@ -2318,7 +2318,7 @@ async def test_replicate_disconnect_redis_cluster(redis_cluster, df_factory, df_
fill_task = asyncio.create_task(seeder.run())
proxy = Proxy("127.0.0.1", 1114, "127.0.0.1", redis_cluster_nodes[1].port)
proxy = Proxy("127.0.0.1", next(next_port), "127.0.0.1", redis_cluster_nodes[1].port)
await proxy.start()
proxy_task = asyncio.create_task(proxy.serve())
@ -2374,6 +2374,7 @@ async def test_replicate_disconnect_redis_cluster(redis_cluster, df_factory, df_
await c_replica.execute_command("REPLICAOF NO ONE")
capture = await seeder.capture()
assert await seeder.compare(capture, replica.port)
await proxy.close(proxy_task)
@pytest.mark.skip("Takes more than 10 minutes")