blob: cbf068f0b8517b3861b4aef9b9e9e9f72e0f1c8d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
# frozen_string_literal: true
module AuthorizedProjectUpdate
class ProjectRecalculateWorker
include ApplicationWorker
data_consistency :always
include Gitlab::ExclusiveLeaseHelpers
prepend WaitableWorker
feature_category :system_access
urgency :high
queue_namespace :authorized_project_update
deduplicate :until_executing, including_scheduled: true
idempotent!
def perform(project_id)
project = Project.find_by_id(project_id)
return unless project
in_lock(lock_key(project), ttl: 10.seconds) do
AuthorizedProjectUpdate::ProjectRecalculateService.new(project).execute
end
end
private
def lock_key(project)
# The self.class.name.underscore value is hardcoded here as the prefix, so that the same
# lock_key for this superclass will be used by the ProjectRecalculatePerUserWorker subclass.
"authorized_project_update/project_recalculate_worker/projects/#{project.id}"
end
end
end
|
