|  |  | @ -551,7 +551,8 @@ class Worker(object): | 
			
		
	
		
		
			
				
					
					|  |  |  |             registry = StartedJobRegistry(job.origin, self.connection) |  |  |  |             registry = StartedJobRegistry(job.origin, self.connection) | 
			
		
	
		
		
			
				
					
					|  |  |  |             registry.add(job, timeout, pipeline=pipeline) |  |  |  |             registry.add(job, timeout, pipeline=pipeline) | 
			
		
	
		
		
			
				
					
					|  |  |  |             job.set_status(JobStatus.STARTED, pipeline=pipeline) |  |  |  |             job.set_status(JobStatus.STARTED, pipeline=pipeline) | 
			
		
	
		
		
			
				
					
					|  |  |  |             job.set_started_at_now(pipeline=pipeline) |  |  |  |             self.connection._hset(job.key, 'started_at', | 
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					|  |  |  |  |  |  |  |                                   utcformat(utcnow()), pipeline) | 
			
		
	
		
		
			
				
					
					|  |  |  |             pipeline.execute() |  |  |  |             pipeline.execute() | 
			
		
	
		
		
			
				
					
					|  |  |  | 
 |  |  |  | 
 | 
			
		
	
		
		
			
				
					
					|  |  |  |         msg = 'Processing {0} from {1} since {2}' |  |  |  |         msg = 'Processing {0} from {1} since {2}' | 
			
		
	
	
		
		
			
				
					|  |  | 
 |