github-mirror/discourse
2
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2025-06-09 06:06:44 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

FIX: don't allow concurrently queued once off jobs to do work

Browse Source
This commit is contained in:
Sam
2016-04-12 23:08:10 +10:00
parent 72849e65de
commit eda6084d4b
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
app/jobs/onceoff.rb
View File

@ -12,6 +12,7 @@ class Jobs::Onceoff < Jobs::Base
if args[:force] || !OnceoffLog.where(job_name: job_name).exists? if args[:force] || !OnceoffLog.where(job_name: job_name).exists?
return if $redis.exists(self.class.name) return if $redis.exists(self.class.name)
DistributedMutex.synchronize(self.class.name) do DistributedMutex.synchronize(self.class.name) do
return if OnceoffLog.where(job_name: job_name).exists? && !args[:force]
execute_onceoff(args) execute_onceoff(args)
OnceoffLog.create(job_name: job_name) OnceoffLog.create(job_name: job_name)
end end