mirror of
https://github.com/dragonflydb/dragonfly.git
synced 2025-05-10 18:05:44 +02:00
fix(test): seeder test remove check (#4320)
fix test: seeder test remove check Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
parent
dfd942d749
commit
0fe5e86a1a
1 changed files with 3 additions and 3 deletions
|
@ -18,8 +18,9 @@ async def test_static_seeder(async_client: aioredis.Redis):
|
||||||
async def test_static_collection_size(async_client: aioredis.Redis):
|
async def test_static_collection_size(async_client: aioredis.Redis):
|
||||||
async def check_list():
|
async def check_list():
|
||||||
keys = await async_client.keys()
|
keys = await async_client.keys()
|
||||||
assert (await async_client.llen(keys[0])) == 1
|
for key in keys:
|
||||||
assert len(await async_client.lpop(keys[0])) == 10_000
|
assert await async_client.llen(key) == 1
|
||||||
|
assert len(await async_client.lpop(key)) == 10_000
|
||||||
|
|
||||||
s = StaticSeeder(
|
s = StaticSeeder(
|
||||||
key_target=10, data_size=10_000, variance=1, samples=1, collection_size=1, types=["LIST"]
|
key_target=10, data_size=10_000, variance=1, samples=1, collection_size=1, types=["LIST"]
|
||||||
|
@ -39,7 +40,6 @@ async def test_static_collection_size(async_client: aioredis.Redis):
|
||||||
huge_value_size=0,
|
huge_value_size=0,
|
||||||
)
|
)
|
||||||
await s.run(async_client)
|
await s.run(async_client)
|
||||||
await check_list()
|
|
||||||
|
|
||||||
|
|
||||||
@dfly_args({"proactor_threads": 4})
|
@dfly_args({"proactor_threads": 4})
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue