15
16
17
18
19
20
21
22
23
24
|
# File 'lib/esse/async_indexing/workers/sidekiq.rb', line 15
def service_worker_options
default_queue = Esse.config.async_indexing.sidekiq.workers.dig(name, :queue)
default_retry = Esse.config.async_indexing.sidekiq.workers.dig(name, :retry)
default_queue ||= ::Sidekiq.default_worker_options["queue"] if defined?(::Sidekiq)
default_retry ||= ::Sidekiq.default_worker_options["retry"] if defined?(::Sidekiq)
{
queue: default_queue || "default",
retry: default_retry || 15
}
end
|