mirror of
https://github.com/mastodon/mastodon.git
synced 2024-11-25 05:55:19 +01:00
26 lines
515 B
Ruby
26 lines
515 B
Ruby
# frozen_string_literal: true
|
|
|
|
class Admin::SystemCheck::SidekiqProcessCheck < Admin::SystemCheck::BaseCheck
|
|
SIDEKIQ_QUEUES = %w(
|
|
default
|
|
push
|
|
mailers
|
|
pull
|
|
scheduler
|
|
).freeze
|
|
|
|
def pass?
|
|
missing_queues.empty?
|
|
end
|
|
|
|
def message
|
|
Admin::SystemCheck::Message.new(:sidekiq_process_check, missing_queues.join(', '))
|
|
end
|
|
|
|
private
|
|
|
|
def missing_queues
|
|
@missing_queues ||= Sidekiq::ProcessSet.new.reduce(SIDEKIQ_QUEUES) { |queues, process| queues - process['queues'] }
|
|
end
|
|
end
|