Sha256: b23c6c44be86d90ae9c6ba7fd97e26f07a3cd27df0440e66e02370387ce357dc

Contents?: true

Size: 487 Bytes

Versions: 1

Compression:

Stored size: 487 Bytes

Contents

require 'sidekiq/api'

# This initializer inspects the currently scheduled Sidekiq workers,
# of which the Sidekiq::Snitch must always be one in a properly
# configured application.
#
# When none are found, schedule one to run immediately. The worker
# will then take care of rescheduling itself.
set = Sidekiq::ScheduledSet.new
length = set.select {|job| job.klass == "Sidekiq::Snitch" }.length

unless length > 0 || ENV['SIDEKIQ_SNITCH_URL'].blank?
  Sidekiq::Snitch.perform_async
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
sidekiq_snitch-1.1.0 config/initializers/perform.rb