fb6899b90b6bb5d86451f65e210d8527828ba329,perfkitbenchmarker/linux_benchmarks/aerospike_certification_tool_benchmark.py,,Run,#Any#,65

Before Change

    samples.extend(act.RunAct(vm, index))

  if FLAGS.act_parallel:
    vm_util.RunThreaded(_Run, range(len(vm.scratch_disks))[
        FLAGS.act_reserved_partitions:])
  else:
    samples = act.RunAct(vm)
  return samples

After Change

      run_samples.extend(act.RunAct(vm, act_load, index))

    if FLAGS.act_parallel:
      args = [((float(load), idx), {})
              for idx in range(
                  len(vm.scratch_disks))[FLAGS.act_reserved_partitions:]]
      vm_util.RunThreaded(_Run, args)
    else:
      run_samples.extend(act.RunAct(vm, float(load)))
    samples.extend(run_samples)
    if FLAGS.act_stop_on_complete and act.IsRunComplete(run_samples):

Instances