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

fix(regtests): Reduce load on redis replication test (#1984)

Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>
This commit is contained in:
Vladislav 2023-10-03 12:28:42 +03:00 committed by GitHub
parent 945d3a39e4
commit 20b924f9d5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 7 deletions

View file

@ -153,11 +153,11 @@ async def test_replication_stable_sync(
# Threads for each dragonfly replica, Seeder Config.
replication_specs = [
([1], dict(keys=1000, dbcount=1, unsupported_types=[ValueType.JSON])),
([6, 6, 6], dict(keys=4_000, dbcount=4, unsupported_types=[ValueType.JSON])),
([2, 2, 2, 2], dict(keys=4_000, dbcount=4, unsupported_types=[ValueType.JSON])),
([8, 8], dict(keys=4_000, dbcount=4, unsupported_types=[ValueType.JSON])),
([1] * 8, dict(keys=500, dbcount=2, unsupported_types=[ValueType.JSON])),
([1], dict(keys=100, dbcount=2, unsupported_types=[ValueType.JSON])),
([6, 6, 6], dict(keys=4_000, dbcount=2, unsupported_types=[ValueType.JSON])),
([2, 2, 2, 2], dict(keys=4_000, dbcount=2, unsupported_types=[ValueType.JSON])),
([8, 8], dict(keys=4_000, dbcount=2, unsupported_types=[ValueType.JSON])),
([1] * 8, dict(keys=500, dbcount=1, unsupported_types=[ValueType.JSON])),
([1], dict(keys=100, dbcount=4, unsupported_types=[ValueType.JSON])),
]

View file

@ -167,9 +167,10 @@ class CommandGenerator:
return ("v0", 0, "v1", 0) + tuple(itertools.chain(*elements))
elif t == ValueType.ZSET:
# Random sequnce of k-letter members and int score for ZADD
# The length of the sequence will vary between val_size/4 and 130. This ensures that we test both the ZSET implementation with Lispack and the bptree.
# The length of the sequence will vary between val_size/4 and 130.
# This ensures that we test both the ZSET implementation with listpack and the our custom BPtree.
value_sizes = [self.val_size // 4, 130]
probabilities = [4, 1]
probabilities = [8, 1]
value_size = random.choices(value_sizes, probabilities)[0]
elements = ((random.randint(0, self.val_size), rand_str()) for _ in range(value_size))
return tuple(itertools.chain(*elements))