summaryrefslogtreecommitdiff
path: root/app/workers/concerns
diff options
context:
space:
mode:
authorGitLab Bot <gitlab-bot@gitlab.com>2020-06-17 00:16:40 +0000
committerGitLab Bot <gitlab-bot@gitlab.com>2020-06-17 00:16:40 +0000
commit35c9eaced5ac35f942cab44d92ed39f3cfa2f8dd (patch)
tree1dda894c02c06b9cc7a2310a55a9912de097ddbf /app/workers/concerns
parenta2dbe2a8d84ce6d97e3a55676cea2f7054310f42 (diff)
downloadgitlab-ce-35c9eaced5ac35f942cab44d92ed39f3cfa2f8dd.tar.gz
Add latest changes from gitlab-org/gitlab@master
Diffstat (limited to 'app/workers/concerns')
-rw-r--r--app/workers/concerns/worker_attributes.rb14
1 files changed, 14 insertions, 0 deletions
diff --git a/app/workers/concerns/worker_attributes.rb b/app/workers/concerns/worker_attributes.rb
index 7fa56c25210..b19217b15de 100644
--- a/app/workers/concerns/worker_attributes.rb
+++ b/app/workers/concerns/worker_attributes.rb
@@ -119,6 +119,20 @@ module WorkerAttributes
Array(worker_attributes[:tags])
end
+ def deduplicate(strategy, options = {})
+ worker_attributes[:deduplication_strategy] = strategy
+ worker_attributes[:deduplication_options] = options
+ end
+
+ def get_deduplicate_strategy
+ worker_attributes[:deduplication_strategy] ||
+ Gitlab::SidekiqMiddleware::DuplicateJobs::DuplicateJob::DEFAULT_STRATEGY
+ end
+
+ def get_deduplication_options
+ worker_attributes[:deduplication_options] || {}
+ end
+
protected
# Returns a worker attribute declared on this class or its parent class.