|  | @@ -383,12 +383,6 @@ class ResultHandler(PoolThread):
 | 
											
												
													
														|  |                  on_state_change(task)
 |  |                  on_state_change(task)
 | 
											
												
													
														|  |              join_exited_workers()
 |  |              join_exited_workers()
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  | -            job, i, obj = task
 |  | 
 | 
											
												
													
														|  | -            try:
 |  | 
 | 
											
												
													
														|  | -                cache[job]._set(i, obj)
 |  | 
 | 
											
												
													
														|  | -            except KeyError:
 |  | 
 | 
											
												
													
														|  | -                pass
 |  | 
 | 
											
												
													
														|  | -
 |  | 
 | 
											
												
													
														|  |          if hasattr(outqueue, '_reader'):
 |  |          if hasattr(outqueue, '_reader'):
 | 
											
												
													
														|  |              debug('ensuring that outqueue is not full')
 |  |              debug('ensuring that outqueue is not full')
 | 
											
												
													
														|  |              # If we don't make room available in outqueue then
 |  |              # If we don't make room available in outqueue then
 |