starred/crono
1
0
Fork 0
mirror of https://github.com/plashchynski/crono.git synced 2026-04-23 17:28:45 +02:00
Code Issues 35 Packages Projects Releases 9 Wiki Activity

Fix empty job_options error

Browse Source
This commit is contained in:
Dzmitry Plashchynski
2016-11-30 00:52:54 +02:00
parent 1cf37ee30f
commit c336b6d00b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/crono/job.rb
View File

@@ -9,13 +9,13 @@ module Crono
attr_accessor :performer, :period, :job_args, :last_performed_at, :job_options, attr_accessor :performer, :period, :job_args, :last_performed_at, :job_options,
:next_performed_at, :job_log, :job_logger, :healthy, :execution_interval :next_performed_at, :job_log, :job_logger, :healthy, :execution_interval
def initialize(performer, period, job_args, job_options = {}) def initialize(performer, period, job_args, job_options = nil)
self.execution_interval = 0.minutes self.execution_interval = 0.minutes
self.performer, self.period = performer, period self.performer, self.period = performer, period
self.job_args = JSON.generate(job_args) self.job_args = JSON.generate(job_args)
self.job_log = StringIO.new self.job_log = StringIO.new
self.job_logger = Logger.new(job_log) self.job_logger = Logger.new(job_log)
self.job_options = job_options self.job_options = job_options || {}
self.next_performed_at = period.next self.next_performed_at = period.next
@semaphore = Mutex.new @semaphore = Mutex.new
end end