From 57ef712243fa2d04817885aaf53afbf5526fb8aa Mon Sep 17 00:00:00 2001 From: Pavel Emelyanov Date: Mon, 23 Mar 2026 17:01:20 +0300 Subject: [PATCH] test/backup: drop create_dataset helper It has no more callers after the previous patch. Signed-off-by: Pavel Emelyanov Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --- test/cluster/object_store/test_backup.py | 25 ------------------------ 1 file changed, 25 deletions(-) diff --git a/test/cluster/object_store/test_backup.py b/test/cluster/object_store/test_backup.py index d5b21209d6..f858dd739e 100644 --- a/test/cluster/object_store/test_backup.py +++ b/test/cluster/object_store/test_backup.py @@ -494,31 +494,6 @@ async def create_cluster(topology, manager, logger, object_storage=None): return servers,host_ids -async def create_dataset(manager, ks, cf, topology, logger, num_keys=256, min_tablet_count=None, schema=None, consistency_level=ConsistencyLevel.ALL): - cql = manager.get_cql() - logger.info(f'Create keyspace, {topology=}') - keys = range(num_keys) - replication_opts = {'class': 'NetworkTopologyStrategy'} - replication_opts['replication_factor'] = f'{topology.rf}' - replication_opts = format_tuples(replication_opts) - - print(replication_opts) - - cql.execute((f"CREATE KEYSPACE {ks} WITH REPLICATION = {replication_opts};")) - - if schema is None: - if min_tablet_count is not None: - logger.info(f'Creating schema with min_tablet_count={min_tablet_count}') - schema = create_schema(ks, cf, min_tablet_count) - cql.execute(schema) - - stmt = cql.prepare(f"INSERT INTO {ks}.{cf} ( pk, value ) VALUES (?, ?)") - if consistency_level is not None: - stmt.consistency_level = consistency_level - await asyncio.gather(*(cql.run_async(stmt, (str(k), k)) for k in keys)) - - return schema, keys, replication_opts - async def do_restore_server(manager, logger, ks, cf, s, toc_names, scope, primary_replica_only, prefix, object_storage): logger.info(f'Restore {s.ip_addr} with {toc_names}, scope={scope}') tid = await manager.api.restore(s.ip_addr, ks, cf, object_storage.address, object_storage.bucket_name, prefix, toc_names, scope, primary_replica_only=primary_replica_only)