|  | @@ -328,10 +328,10 @@ def perf_report_processor_job(worker_host, perf_base_name, output_filename,
 | 
	
		
			
				|  |  |      cmd = ''
 | 
	
		
			
				|  |  |      if worker_host != 'localhost':
 | 
	
		
			
				|  |  |          user_at_host = "%s@%s" % (_REMOTE_HOST_USERNAME, worker_host)
 | 
	
		
			
				|  |  | -        cmd = "USER_AT_HOST=%s OUTPUT_FILENAME=%s OUTPUT_DIR=%s PERF_BASE_NAME=%stools/run_tests/performance/process_remote_perf_flamegraphs.sh" % (
 | 
	
		
			
				|  |  | +        cmd = "USER_AT_HOST=%s OUTPUT_FILENAME=%s OUTPUT_DIR=%s PERF_BASE_NAME=%s tools/run_tests/performance/process_remote_perf_flamegraphs.sh" % (
 | 
	
		
			
				|  |  |              user_at_host, output_filename, flame_graph_reports, perf_base_name)
 | 
	
		
			
				|  |  |      else:
 | 
	
		
			
				|  |  | -        cmd = "OUTPUT_FILENAME=%s OUTPUT_DIR=%s PERF_BASE_NAME=%stools/run_tests/performance/process_local_perf_flamegraphs.sh" % (
 | 
	
		
			
				|  |  | +        cmd = "OUTPUT_FILENAME=%s OUTPUT_DIR=%s PERF_BASE_NAME=%s tools/run_tests/performance/process_local_perf_flamegraphs.sh" % (
 | 
	
		
			
				|  |  |              output_filename, flame_graph_reports, perf_base_name)
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      return jobset.JobSpec(
 | 
	
	
		
			
				|  | @@ -484,7 +484,7 @@ def run_collect_perf_profile_jobs(hosts_and_base_names, scenario_name,
 | 
	
		
			
				|  |  |      failures, _ = jobset.run(
 | 
	
		
			
				|  |  |          perf_report_jobs, newline_on_success=True, maxjobs=1)
 | 
	
		
			
				|  |  |      jobset.message(
 | 
	
		
			
				|  |  | -        'END', 'Collecting perf reports from qps workers', do_newline=True)
 | 
	
		
			
				|  |  | +        'SUCCESS', 'Collecting perf reports from qps workers', do_newline=True)
 | 
	
		
			
				|  |  |      return failures
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |  
 |