Class: Libis::Workflow::Worker
- Inherits:
-
Object
- Object
- Libis::Workflow::Worker
- Includes:
- Sidekiq::Worker
- Defined in:
- lib/libis/workflow/worker.rb
Instance Method Summary collapse
- #configure(job_config, options = {}) ⇒ Object
- #get_job(job_config) ⇒ Object
- #perform(job_config, options = {}) ⇒ Object
Instance Method Details
#configure(job_config, options = {}) ⇒ Object
19 20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/libis/workflow/worker.rb', line 19 def configure(job_config, = {}) log_path = .delete :log_path if log_path Libis::Workflow::Config.logger = ::Logger.new( File.join(log_path, "#{job_config[:name]}.log"), (.delete(:log_shift_age) || 'daily'), (.delete(:log_shift_size) || 1024 ** 2) ) Libis::Workflow::Config.logger.formatter = ::Logger::Formatter.new Libis::Workflow::Config.logger.level = (.delete(:log_level) || ::Logger::DEBUG) end get_job(job_config) end |
#get_job(job_config) ⇒ Object
33 34 35 36 37 |
# File 'lib/libis/workflow/worker.rb', line 33 def get_job(job_config) job = ::Libis::Workflow::Job.new job.configure job_config.key_symbols_to_strings(recursive: true) job end |
#perform(job_config, options = {}) ⇒ Object
13 14 15 16 17 |
# File 'lib/libis/workflow/worker.rb', line 13 def perform(job_config, = {}) job = configure(job_config, ) [:interactive] = false job.execute end |