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

test: fix test_scripts (#3485)

Browse source
This commit is contained in:
Borys 2024-08-09 11:15:47 +03:00 • committed by GitHub
parent b9cafaab4b
commit 7ff56c5ab7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
tests/dragonfly/replication_test.py
View file

@ -860,7 +860,6 @@ return 'OK'
""" """
@pytest.mark.skip(reason="Failing")
@pytest.mark.asyncio @pytest.mark.asyncio
@pytest.mark.parametrize("t_master, t_replicas, num_ops, num_keys, num_par, flags", script_cases) @pytest.mark.parametrize("t_master, t_replicas, num_ops, num_keys, num_par, flags", script_cases)
async def test_scripts(df_factory, t_master, t_replicas, num_ops, num_keys, num_par, flags): async def test_scripts(df_factory, t_master, t_replicas, num_ops, num_keys, num_par, flags):
@ -891,7 +890,9 @@ async def test_scripts(df_factory, t_master, t_replicas, num_ops, num_keys, num_
for key_set in key_sets: for key_set in key_sets:
for j, k in enumerate(key_set): for j, k in enumerate(key_set):
l = await c_replica.lrange(k, 0, -1) l = await c_replica.lrange(k, 0, -1)
assert l == [f"{j}".encode()] * num_ops assert l == [f"{j}"] * num_ops
await close_clients(c_master, *c_replicas)
@dfly_args({"proactor_threads": 4}) @dfly_args({"proactor_threads": 4})