def After(self, unused_sender, benchmark_spec):
    logging.info('Stopping collectd')
    vms = benchmark_spec.vms
    vm_util.RunThreaded(self._FetchResults, vms)
Stop / delete collectd, fetch results from VMs.
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/traces/collectd.py/_CollectdCollector.After