test: add test_cache_cluster_data_migration #4435
Conversation
BorysTheDev
force-pushed
the
eviction_during_migration
branch
from
8555c1d to
a023cae
Compare
BorysTheDev
changed the title
BorysTheDev
changed the title
BorysTheDev
force-pushed
the
eviction_during_migration
branch
from
e4f3fdc to
30094db
Compare
BorysTheDev
force-pushed
the
eviction_during_migration
branch
from
30094db to
20c3c91
Compare
BorysTheDev
force-pushed
the
eviction_during_migration
branch
from
20c3c91 to
334a081
Compare
BorysTheDev
changed the title
BorysTheDev
force-pushed
the
eviction_during_migration
branch
from
334a081 to
baf2978
Compare
|
|
||
| gen_stop = False | ||
|
|
||
| async def expiration_gen(): |
There was a problem hiding this comment.
you can use ExpirySeeder
| i = 0 | ||
| try: | ||
| while not gen_stop: | ||
| await nodes[0].client.execute_command(f"SET exp_key_{i} val_{i} EX 20") |
There was a problem hiding this comment.
When I run your test the first call here gets OOM exeptions therefor no command here is executed
There was a problem hiding this comment.
I think it's ok if test is finished successfully
There was a problem hiding this comment.
but it sometimes fails at least for me
There was a problem hiding this comment.
it's interesting, where?
There was a problem hiding this comment.
last assertion assert stats["expired_keys"] > 0
| fill_exp_task = asyncio.create_task(expiration_gen()) | ||
|
|
||
| # some time to fill data | ||
| await asyncio.sleep(20) |
There was a problem hiding this comment.
to fill enough data and start some keys expire
There was a problem hiding this comment.
the first debug populate fills enough data for evictions as far as I understand.
also you can use a smaller expiration time to check expiry f.e 2 seconds
There was a problem hiding this comment.
2 seconds isn't enough because it's random
There was a problem hiding this comment.
we don't know what the slot of the next key and if the interval is small we can get already migrated slots keys or they will expire before migration
fixes: #4354