diff --git a/app/jobs/security_health_check_job.rb b/app/jobs/security_health_check_job.rb index 7b56cc31..387dcd9b 100644 --- a/app/jobs/security_health_check_job.rb +++ b/app/jobs/security_health_check_job.rb @@ -2,6 +2,6 @@ class SecurityHealthCheckJob < ApplicationJob queue_as :scheduled def perform - Security::HealthChecker.new.perform + Security::HealthChecker.check_all end end diff --git a/app/models/security/health_checker.rb b/app/models/security/health_checker.rb index 16778fda..b10bfb60 100644 --- a/app/models/security/health_checker.rb +++ b/app/models/security/health_checker.rb @@ -23,7 +23,7 @@ class Security::HealthChecker end # Daily limit for checked securities - due_for_check_scope.limit(DAILY_BATCH_SIZE).find_each do |security| + due_for_check_scope.limit(DAILY_BATCH_SIZE).each do |security| new(security).run_check end end @@ -48,6 +48,8 @@ class Security::HealthChecker end def run_check + Rails.logger.info("Running health check for #{security.ticker}") + if latest_provider_price handle_success else @@ -69,6 +71,8 @@ class Security::HealthChecker end def latest_provider_price + return nil unless provider.present? + response = provider.fetch_security_price( symbol: security.ticker, exchange_operating_mic: security.exchange_operating_mic,