diff --git a/tests/dragonfly/replication_test.py b/tests/dragonfly/replication_test.py index 4987848c0..91a7ccef3 100644 --- a/tests/dragonfly/replication_test.py +++ b/tests/dragonfly/replication_test.py @@ -918,6 +918,8 @@ async def test_role_command(df_local_factory, n_keys=20): await c_replica.execute_command(f"REPLICAOF localhost {master.port}") await wait_available_async(c_replica) + await asyncio.sleep(1) + assert await c_master.execute_command("role") == [ b"master", [[b"127.0.0.1", bytes(str(replica.port), "ascii"), b"stable_sync"]],