mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-21 17:10:35 +00:00
a4aa4d74c1
To quickly populate nodes in a single dc, each node in its own rack. Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
38 lines
1.2 KiB
Python
38 lines
1.2 KiB
Python
#
|
|
# Copyright (C) 2022-present ScyllaDB
|
|
#
|
|
# SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
#
|
|
"""
|
|
Test consistency of schema changes with server hard stop.
|
|
"""
|
|
import time
|
|
from test.cluster.util import wait_for_token_ring_and_group0_consistency
|
|
import pytest
|
|
|
|
pytestmark = pytest.mark.prepare_3_racks_cluster
|
|
|
|
|
|
@pytest.mark.asyncio
|
|
async def test_topology_schema_changes(manager, random_tables):
|
|
"""Test schema consistency with restart, add, and sudden stop of servers"""
|
|
table = await random_tables.add_table(ncolumns=5)
|
|
servers = await manager.running_servers()
|
|
|
|
# Test add column after server restart
|
|
await manager.server_restart(servers[1].server_id)
|
|
await manager.servers_see_each_other(servers)
|
|
await table.add_column()
|
|
await random_tables.verify_schema()
|
|
|
|
# Test add column after adding a server
|
|
await manager.server_add(property_file=servers[1].property_file())
|
|
await wait_for_token_ring_and_group0_consistency(manager, time.time() + 30)
|
|
await table.add_column()
|
|
await random_tables.verify_schema()
|
|
|
|
# Test add column after hard stop of a server (1/3)
|
|
await manager.server_stop(servers[1].server_id)
|
|
await table.add_column()
|
|
await random_tables.verify_schema()
|