|  | @@ -534,7 +534,11 @@ class KeyValueStoreBackend(BaseBackend):
 | 
	
		
			
				|  |  |      def _apply_chord_incr(self, header, partial_args, group_id, body,
 | 
	
		
			
				|  |  |                            result=None, options={}, **kwargs):
 | 
	
		
			
				|  |  |          self.save_group(group_id, self.app.GroupResult(group_id, result))
 | 
	
		
			
				|  |  | -        return header(*partial_args, task_id=group_id, **options or {})
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +        fixed_options = dict((k,v) for k,v in options.items() if k != 'task_id')
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +        return header(*partial_args, task_id=group_id, **fixed_options or {})
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      def on_chord_part_return(self, task, state, result, propagate=None):
 | 
	
		
			
				|  |  |          if not self.implements_incr:
 |