c8c2c1c1613641ea9b0161d7a47980d66d5e504c,perfkitbenchmarker/linux_benchmarks/dpb_distcp_benchmark.py,,Cleanup,#Any#,153

Before Change

def Cleanup(benchmark_spec):
  Cleans up the distcp benchmark
  del benchmark_spec  // Unused.

After Change

def Cleanup(benchmark_spec):
  Cleans up the distcp benchmark.
  if (FLAGS.distcp_source_fs != BaseDpbService.HDFS_FS
      or FLAGS.distcp_dest_fs != BaseDpbService.HDFS_FS):
    run_uri = benchmark_spec.uuid.split("-")[0]
    benchmark_spec.dpb_service.DeleteBucket("pkb-" + run_uri)

Instances