| 
						
						
							
								
							
						
						
					 | 
					 | 
					@ -745,17 +745,17 @@ class ExecutionQueue(object):
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      try:
 | 
					 | 
					 | 
					 | 
					      try:
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        self.item.run(*self.args, **self.kwargs)
 | 
					 | 
					 | 
					 | 
					        self.item.run(*self.args, **self.kwargs)
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      except KeyboardInterrupt:
 | 
					 | 
					 | 
					 | 
					      except KeyboardInterrupt:
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        logging.info('Caught KeyboardInterrupt in thread %s' % self.item.name)
 | 
					 | 
					 | 
					 | 
					        logging.info('Caught KeyboardInterrupt in thread %s', self.item.name)
 | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        logging.info(str(sys.exc_info()))
 | 
					 | 
					 | 
					 | 
					        logging.info(str(sys.exc_info()))
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        work_queue.exceptions.put(sys.exc_info())
 | 
					 | 
					 | 
					 | 
					        work_queue.exceptions.put(sys.exc_info())
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        raise
 | 
					 | 
					 | 
					 | 
					        raise
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      except Exception:
 | 
					 | 
					 | 
					 | 
					      except Exception:
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        # Catch exception location.
 | 
					 | 
					 | 
					 | 
					        # Catch exception location.
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        logging.info('Caught exception in thread %s' % self.item.name)
 | 
					 | 
					 | 
					 | 
					        logging.info('Caught exception in thread %s', self.item.name)
 | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        logging.info(str(sys.exc_info()))
 | 
					 | 
					 | 
					 | 
					        logging.info(str(sys.exc_info()))
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        work_queue.exceptions.put(sys.exc_info())
 | 
					 | 
					 | 
					 | 
					        work_queue.exceptions.put(sys.exc_info())
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      finally:
 | 
					 | 
					 | 
					 | 
					      finally:
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        logging.info('_Worker.run(%s) done' % self.item.name)
 | 
					 | 
					 | 
					 | 
					        logging.info('_Worker.run(%s) done', self.item.name)
 | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        work_queue.ready_cond.acquire()
 | 
					 | 
					 | 
					 | 
					        work_queue.ready_cond.acquire()
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        try:
 | 
					 | 
					 | 
					 | 
					        try:
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					          work_queue.ready_cond.notifyAll()
 | 
					 | 
					 | 
					 | 
					          work_queue.ready_cond.notifyAll()
 | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					 | 
					
 
 |