def PreloadCassandraServer(benchmark_spec, metadata):
  if (FLAGS.cassandra_stress_command == 'read' or
      FLAGS.cassandra_stress_command == 'mixed'):
    cassandra_stress_command = 'write'
  elif FLAGS.cassandra_stress_command == 'counter_read':
    cassandra_stress_command = 'counter_write'
  else:
    cassandra_stress_command = FLAGS.cassandra_stress_command
  logging.info('Preloading cassandra database with %s %s operations.',
               metadata['num_preload_keys'], cassandra_stress_command)
  RunCassandraStressTest(
      benchmark_spec.vm_groups[CASSANDRA_GROUP],
      benchmark_spec.vm_groups[CLIENT_GROUP],
      metadata['num_preload_keys'], cassandra_stress_command)
  logging.info('Waiting %s for keyspace to propagate.', PROPAGATION_WAIT_TIME)
  time.sleep(PROPAGATION_WAIT_TIME)
Return only the network location portion of the given domain
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/cassandra_stress_benchmark.py/PreloadCassandraServer--crossover with--dataset/ETHPy150Open bear/python-indieweb/indieweb.py/baseDomain