def Run(benchmark_spec):
  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'],
      metadata['population_parameters'])
  return CollectResults(benchmark_spec, metadata)
Run Cassandra on target vms.
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/cassandra_stress_benchmark.py/Run