Change: #420 絵文字リアクションストリーミングWorkerのキューの種類を新規作成 (#551)

* Change: #420 絵文字リアクションストリーミングWorkerのキューの種類を`push`に変更

* `perishable`キュー新規作成に変更

* 優先順位を`ingress`と一緒に
This commit is contained in:
KMY(雪あすか) 2024-02-15 12:59:27 +09:00 committed by GitHub
parent 8a29aef842
commit 91cb329e18
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
4 changed files with 6 additions and 2 deletions

View file

@ -8,6 +8,7 @@ class Admin::SystemCheck::SidekiqProcessCheck < Admin::SystemCheck::BaseCheck
pull
scheduler
ingress
perishable
).freeze
def skip?

View file

@ -6,6 +6,8 @@ class DeliveryEmojiReactionWorker
include Lockable
include AccountScope
sidekiq_options queue: 'perishable'
def perform(payload_json, status_id, reacted_account_id)
return unless Setting.enable_emoji_reaction

View file

@ -4,6 +4,7 @@
- [default, 8]
- [push, 6]
- [ingress, 4]
- [perishable, 4]
- [mailers, 2]
- [pull]
- [scheduler]

View file

@ -35,11 +35,11 @@ describe Admin::SystemCheck::SidekiqProcessCheck do
describe 'message' do
it 'sends values to message instance' do
allow(Admin::SystemCheck::Message).to receive(:new).with(:sidekiq_process_check, 'default, push, mailers, pull, scheduler, ingress')
allow(Admin::SystemCheck::Message).to receive(:new).with(:sidekiq_process_check, 'default, push, mailers, pull, scheduler, ingress, perishable')
check.message
expect(Admin::SystemCheck::Message).to have_received(:new).with(:sidekiq_process_check, 'default, push, mailers, pull, scheduler, ingress')
expect(Admin::SystemCheck::Message).to have_received(:new).with(:sidekiq_process_check, 'default, push, mailers, pull, scheduler, ingress, perishable')
end
end
end