mirror of https://github.com/rq/rq.git
parent
193de26cff
commit
d5e55ab95a
|
@ -1498,6 +1498,12 @@ class Worker(BaseWorker):
|
||||||
# self.execution.delete(pipeline) # type: ignore
|
# self.execution.delete(pipeline) # type: ignore
|
||||||
|
|
||||||
pipeline.execute()
|
pipeline.execute()
|
||||||
|
|
||||||
|
time_taken = job.ended_at - job.started_at
|
||||||
|
self.log.info(
|
||||||
|
'Successfully completed %s job in %ss on worker %s', job.description, time_taken, self.name
|
||||||
|
)
|
||||||
|
|
||||||
self.log.debug('Finished handling successful execution of job %s', job.id)
|
self.log.debug('Finished handling successful execution of job %s', job.id)
|
||||||
break
|
break
|
||||||
except redis.exceptions.WatchError:
|
except redis.exceptions.WatchError:
|
||||||
|
|
Loading…
Reference in New Issue