lib/sidekiq_bus/adapter.rb in sidekiq-bus-0.8.1 vs lib/sidekiq_bus/adapter.rb in sidekiq-bus-0.8.2
- old
+ new
@@ -55,10 +55,10 @@
private
def set_schedule(queue_name)
::Sidekiq.set_schedule(
'sidekiqbus_heartbeat',
- every: '1min',
+ cron: '0 * * * * *', # Runs every minute
class: ::QueueBus::Worker.name,
args: [
::QueueBus::Util.encode('bus_class_proxy' => ::QueueBus::Heartbeat.name)
],
queue: queue_name,