123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- class BackgroundServices::Service
- include BackgroundServices::Concerns::HasInterruptibleSleep
- include Mixin::RequiredSubPaths
- attr_reader :fork_id, :manager
- def self.service_name
- name.demodulize
- end
-
- def self.max_workers
- 1
- end
- def self.skip?(manager:)
- false
- end
-
-
- def self.pre_run
- run_in_service_context do
- pre_launch
- end
- end
- def self.run_in_service_context(&)
- Rails.application.executor.wrap do
- ApplicationHandleInfo.use('scheduler', &)
- end
- end
- def initialize(manager:, fork_id: nil)
- @fork_id = fork_id
- @manager = manager
- end
-
- def run
- self.class.run_in_service_context do
- launch
- rescue => e
-
- Rails.logger.error { "#{self.class.name}
- Rails.logger.error { e }
- raise e
- end
- end
- protected
- # Override this method in service classes.
- def launch; end
- class << self
- protected
- # Override this method in service classes that need to perform tasks once
- # before threads/workers are started.
- def pre_launch; end
- end
- end
|