|  |  | @ -53,9 +53,9 @@ def log_thumbnail(thumbnailMsg): | 
			
		
	
		
		
			
				
					
					|  |  |  |   rr.log("/thumbnail", rr.ImageEncoded(contents=bytesImgData)) |  |  |  |   rr.log("/thumbnail", rr.ImageEncoded(contents=bytesImgData)) | 
			
		
	
		
		
			
				
					
					|  |  |  | 
 |  |  |  | 
 | 
			
		
	
		
		
			
				
					
					|  |  |  | @rr.shutdown_at_exit |  |  |  | @rr.shutdown_at_exit | 
			
		
	
		
		
			
				
					
					|  |  |  | def process(lr): |  |  |  | def process(blueprint, lr): | 
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					|  |  |  |   rr.init("rerun_test") |  |  |  |   rr.init("rerun_test") | 
			
		
	
		
		
			
				
					
					|  |  |  |   rr.connect() |  |  |  |   rr.connect(default_blueprint=blueprint) | 
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					|  |  |  | 
 |  |  |  | 
 | 
			
		
	
		
		
			
				
					
					|  |  |  |   ret = [] |  |  |  |   ret = [] | 
			
		
	
		
		
			
				
					
					|  |  |  |   for msg in lr: |  |  |  |   for msg in lr: | 
			
		
	
	
		
		
			
				
					|  |  | @ -80,10 +80,10 @@ if __name__ == '__main__': | 
			
		
	
		
		
			
				
					
					|  |  |  |   args = parser.parse_args() |  |  |  |   args = parser.parse_args() | 
			
		
	
		
		
			
				
					
					|  |  |  | 
 |  |  |  | 
 | 
			
		
	
		
		
			
				
					
					|  |  |  |   blueprint = createBlueprint() |  |  |  |   blueprint = createBlueprint() | 
			
		
	
		
		
			
				
					
					|  |  |  |   rr.init("rerun_test", default_blueprint=blueprint) |  |  |  |   rr.init("rerun_test") | 
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					|  |  |  |   rr.spawn(connect=False) # child processes stream data to Viewer |  |  |  |   rr.spawn(connect=False) # child processes stream data to Viewer | 
			
		
	
		
		
			
				
					
					|  |  |  | 
 |  |  |  | 
 | 
			
		
	
		
		
			
				
					
					|  |  |  |   route_or_segment_name = DEMO_ROUTE if args.demo else args.route_or_segment_name.strip() |  |  |  |   route_or_segment_name = DEMO_ROUTE if args.demo else args.route_or_segment_name.strip() | 
			
		
	
		
		
			
				
					
					|  |  |  |   print("Getting route log paths") |  |  |  |   print("Getting route log paths") | 
			
		
	
		
		
			
				
					
					|  |  |  |   lr = LogReader(route_or_segment_name) |  |  |  |   lr = LogReader(route_or_segment_name) | 
			
		
	
		
		
			
				
					
					|  |  |  |   lr.run_across_segments(NUM_CPUS, partial(process)) |  |  |  |   lr.run_across_segments(NUM_CPUS, partial(process, blueprint)) | 
			
				
				
			
		
	
		
		
	
	
		
		
			
				
					|  |  | 
 |