Commit a96fb3a2 authored by Nick Thomas's avatar Nick Thomas

Give each elasticsearch worker its own sidekiq queue

parent 5c5026c8
class ElasticCommitIndexerWorker
include Sidekiq::Worker
include DedicatedSidekiqQueue
include Gitlab::CurrentSettings
sidekiq_options queue: :elasticsearch, retry: 2
sidekiq_options retry: 2
def perform(project_id, oldrev = nil, newrev = nil)
return true unless current_application_settings.elasticsearch_indexing?
......
class ElasticIndexerWorker
include Sidekiq::Worker
include DedicatedSidekiqQueue
include Elasticsearch::Model::Client::ClassMethods
include Gitlab::CurrentSettings
sidekiq_options queue: :elasticsearch, retry: 2
sidekiq_options retry: 2
ISSUE_TRACKED_FIELDS = %w(assignee_id author_id confidential).freeze
......
---
title: Give each elasticsearch worker its own sidekiq queue
merge_request:
author:
......@@ -54,11 +54,12 @@
- [pages, 1]
- [system_hook_push, 1]
# EE specific queues
- [elasticsearch, 1]
- [geo, 1]
- [project_mirror, 1]
- [project_update_repository_storage, 1]
- [admin_emails, 1]
- [geo_repository_update, 1]
- [elastic_batch_project_indexer, 1]
- [elastic_indexer_worker, 1]
- [elastic_commit_indexer_worker, 1]
- [export_csv, 1]
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment