

def Run(benchmark_spec):
    'Run Cassandra on target vms.\n\n  Args:\n    benchmark_spec: The benchmark specification. Contains all data\n        that is required to run the benchmark.\n\n  Returns:\n    A list of sample.Sample objects.\n  '
    metadata = GenerateMetadataFromFlags(benchmark_spec)
    RunCassandraStressTest(benchmark_spec.vm_groups[CASSANDRA_GROUP], benchmark_spec.vm_groups[CLIENT_GROUP], metadata['num_keys'], metadata['command'], metadata.get('operations'), metadata['population_size'], metadata['population_dist'], benchmark_spec['population_parameters'])
    return CollectResults(benchmark_spec, metadata)

dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/cassandra_stress_benchmark.py Run/VarMisuse@62/185 `metadata`->`benchmark_spec`