pre-warm redis server version cache of job from queue (#1727)

Co-authored-by: Jan Rüegg <jrueegg@apple.com>
main
Jan Rüegg 2 years ago committed by GitHub
parent 67432ec8be
commit 09856f9924
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -559,6 +559,7 @@ class Queue:
# Add Queue key set # Add Queue key set
pipe.sadd(self.redis_queues_keys, self.key) pipe.sadd(self.redis_queues_keys, self.key)
job.redis_server_version = self.get_redis_server_version()
job.set_status(JobStatus.QUEUED, pipeline=pipe) job.set_status(JobStatus.QUEUED, pipeline=pipe)
job.origin = self.name job.origin = self.name

Loading…
Cancel
Save