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

fix: test_migration_timeout_on_sync (#4933)

Browse source
This commit is contained in:
Borys 2025-04-14 20:59:42 +03:00 • committed by GitHub
parent eeb27f3569
commit 5fc585b272
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/server/debugcmd.cc
View file

@ -510,6 +510,8 @@ void DebugCmd::Run(CmdArgList args, facade::SinkReplyBuilder* builder) {
" existing RDB file.",
"REPLICA PAUSE/RESUME",
" Stops replica from reconnecting to master, or resumes",
"MIGRATION PAUSE/RESUME",
" Stops/resumes incoming migration process only in the SYNC state",
"REPLICA OFFSET",
" Return sync id and array of number of journal commands executed for each replica flow",
"WATCHED",

3
tests/dragonfly/cluster_test.py
View file

@ -2745,7 +2745,8 @@ async def test_migration_timeout_on_sync(df_factory: DflyInstanceFactory, df_see
await push_config(json.dumps(generate_config(nodes)), [node.admin_client for node in nodes])
await asyncio.sleep(random.randint(0, 50) / 100)
await wait_for_migration_start(nodes[1].admin_client, nodes[0].id)
# to pause migration we need to be in sync state
await wait_for_status(nodes[1].admin_client, nodes[0].id, "SYNC", 1000)
logging.debug("debug migration pause")
await nodes[1].client.execute_command("debug migration pause")