record background queue stats in a worker (#5533) [deploy]
This commit is contained in:
parent
97aac4ef9b
commit
5962d52a61
3 changed files with 26 additions and 2 deletions
10
app/workers/metrics/record_background_queue_stats_worker.rb
Normal file
10
app/workers/metrics/record_background_queue_stats_worker.rb
Normal file
|
|
@ -0,0 +1,10 @@
|
|||
module Metrics
|
||||
class RecordBackgroundQueueStatsWorker
|
||||
include Sidekiq::Worker
|
||||
sidekiq_options queue: :low_priority, retry: 10
|
||||
|
||||
def perform
|
||||
Loggers::LogWorkerQueueStats.run
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
@ -113,9 +113,9 @@ task fix_credits_count_cache: :environment do
|
|||
end
|
||||
|
||||
task record_db_table_counts: :environment do
|
||||
RecordDbTableCountsWorker.perform_async
|
||||
Metrics::RecordDbTableCountsWorker.perform_async
|
||||
end
|
||||
|
||||
task log_worker_queue_stats: :environment do
|
||||
Loggers::LogWorkerQueueStats.run
|
||||
Metrics::RecordBackgroundQueueStatsWorker.perform_async
|
||||
end
|
||||
|
|
|
|||
|
|
@ -0,0 +1,14 @@
|
|||
require "rails_helper"
|
||||
|
||||
RSpec.describe Metrics::RecordBackgroundQueueStatsWorker, type: :worker do
|
||||
include_examples "#enqueues_on_correct_queue", "low_priority", 1
|
||||
|
||||
describe "#perform" do
|
||||
it "logs estimated counts in Datadog" do
|
||||
allow(Loggers::LogWorkerQueueStats).to receive(:run)
|
||||
described_class.new.perform
|
||||
|
||||
expect(Loggers::LogWorkerQueueStats).to have_received(:run)
|
||||
end
|
||||
end
|
||||
end
|
||||
Loading…
Add table
Reference in a new issue