diff options
author | James Lopez <james@jameslopez.es> | 2017-05-05 19:01:33 +0300 |
---|---|---|
committer | James Lopez <james@jameslopez.es> | 2017-05-05 19:01:33 +0300 |
commit | 6ecf16b8f70335e1e6868b7c918cd031f5eb2f8d (patch) | |
tree | e57683de43fa63c278929bcba679d1077906a2fe /app/workers/propagate_service_template_worker.rb | |
parent | ce418036c763219df8239632f71ef0e9782be7ea (diff) |
refactor code based on feedback
Diffstat (limited to 'app/workers/propagate_service_template_worker.rb')
-rw-r--r-- | app/workers/propagate_service_template_worker.rb | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/app/workers/propagate_service_template_worker.rb b/app/workers/propagate_service_template_worker.rb new file mode 100644 index 00000000000..f1fc7ccb955 --- /dev/null +++ b/app/workers/propagate_service_template_worker.rb @@ -0,0 +1,23 @@ +# Worker for updating any project specific caches. +class PropagateServiceTemplateWorker + include Sidekiq::Worker + include DedicatedSidekiqQueue + + sidekiq_options retry: 3 + + LEASE_TIMEOUT = 4.hours.to_i + + def perform(template_id) + return unless try_obtain_lease_for(template_id) + + Projects::PropagateServiceTemplate.propagate(Service.find_by(id: template_id)) + end + + private + + def try_obtain_lease_for(template_id) + Gitlab::ExclusiveLease. + new("propagate_service_template_worker:#{template_id}", timeout: LEASE_TIMEOUT). + try_obtain + end +end |