blob: ed882e3ecefa8b6c9bb1efeff30fa79cf6b9ee38 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
##
# Concern for setting Sidekiq settings for the various CI pipeline workers.
#
module PipelineQueue
extend ActiveSupport::Concern
included do
sidekiq_options queue: 'pipelines-default'
end
class_methods do
def enqueue_in(queue:, group:)
raise ArgumentError if queue.empty? || group.empty?
sidekiq_options queue: "pipelines-#{queue}-#{group}"
end
end
end
|
