diff --git a/lib/symphony/metronome/scheduledevent.rb b/lib/symphony/metronome/scheduledevent.rb index 13fcb10..8926ef6 100644 --- a/lib/symphony/metronome/scheduledevent.rb +++ b/lib/symphony/metronome/scheduledevent.rb @@ -179,9 +179,13 @@ class Symphony::Metronome::ScheduledEvent # a HUP. # if self.event.recurring - now = Time.now - last = self.ds.first[ :lastrun ] - return false if last && now - last < self.event.interval + now = Time.now + row = self.ds.first + + if row + last = row[ :lastrun ] + return false if last && now - last < self.event.interval + end # Mark the time this recurring event was fired. self.ds.update( :lastrun => Time.now ) diff --git a/spec/symphony/metronome/scheduler_spec.rb b/spec/symphony/metronome/scheduler_spec.rb index 73a20d8..e370135 100644 --- a/spec/symphony/metronome/scheduler_spec.rb +++ b/spec/symphony/metronome/scheduler_spec.rb @@ -9,11 +9,6 @@ describe Symphony::Metronome::Scheduler do described_class.configure end - it 'spins up an AMQP listener by default' do - - # described_class.run {} - # expect( described_class.listen ).to eq( :sd ) - - end + # needs tests end