

def Cleanup(benchmark_spec):
    'Cleanup function.\n\n  Args:\n    benchmark_spec: The benchmark specification. Contains all data\n        that is required to run the benchmark.\n  '
    vm_dict = benchmark_spec.vm_groups
    cassandra_vms = vm_dict[CASSANDRA_GROUP]
    vm_util.RunThreaded(cassandra.Stop, cassandra_vms)
    vm_util.RunThreaded(cassandra.CleanNode, cassandra_vms)

dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/cassandra_stress_benchmark.py Cleanup/original