diff --git a/app/services/preview_service/preview_generation_monitor.rb b/app/services/preview_service/generation_monitor.rb similarity index 95% rename from app/services/preview_service/preview_generation_monitor.rb rename to app/services/preview_service/generation_monitor.rb index 74b7c37..98bc2ef 100644 --- a/app/services/preview_service/preview_generation_monitor.rb +++ b/app/services/preview_service/generation_monitor.rb @@ -1,6 +1,7 @@ -# app/services/preview_generation_monitor.rb +require 'sidekiq/api' + module PreviewService - class PreviewGenerationMonitor + class GenerationMonitor class << self def check_stalled_jobs Party.where(preview_state: :queued) diff --git a/config/initializers/scheduler.rb b/config/initializers/scheduler.rb index ec3e92a..1ed6488 100644 --- a/config/initializers/scheduler.rb +++ b/config/initializers/scheduler.rb @@ -5,14 +5,14 @@ unless defined?(Rails::Console) || Rails.env.test? || File.split($0).last == 'ra scheduler = Rufus::Scheduler.new scheduler.every '5m' do - PreviewGenerationMonitor.check_stalled_jobs + PreviewService::GenerationMonitor.check_stalled_jobs end scheduler.every '1h' do - PreviewGenerationMonitor.retry_failed + PreviewService::GenerationMonitor.retry_failed end scheduler.every '1d' do - PreviewGenerationMonitor.cleanup_old_previews + PreviewService::GenerationMonitor.cleanup_old_previews end end