lib/queue_bus/heartbeat.rb in queue-bus-0.5.4 vs lib/queue_bus/heartbeat.rb in queue-bus-0.5.5

- old
+ new

@@ -61,10 +61,10 @@ def set_saved_minute!(epoch_minute) ::QueueBus.redis { |redis| redis.set(redis_key, epoch_minute) } end - def perform + def perform(*args) real_now = Time.now.to_i run_until = lock! - 2 return if run_until < real_now while((real_now = Time.now.to_i) < run_until)