Sha256: eab01d5f0c18364a72e806d9e1ba7767cff9de51fe2d12bab874ebd58a7681db
Contents?: true
Size: 968 Bytes
Versions: 12
Compression:
Stored size: 968 Bytes
Contents
module Kaya
module BackgroundJobs
class Sidekiq
def self.start
workers_dir = workers_dir = __FILE__.split("/")[0..-2].join("/")+ "/workers"
output = Kaya::Support::Console.execute "sidekiq -r #{workers_dir}/execution_checker.rb -d -L kaya/sidekiq_log -P kaya/sidekiq_pid"
print "\n* Sidekiq:"
raise "Could not start Sidekiq correctly. Read kaya/sidekiq_log file for more information" if not started?
print " Started!\n"
end
# Existance of pid file means that sidekiq was started
def self.started?
begin
sec = 0
begin
print "."
return true if IO.read("#{Dir.pwd}/kaya/sidekiq_log") =~ /INFO: Booting Sidekiq \d+.\d+.\d+ with redis options {/
sec += sleep 1
end until sec == 10
puts "Cannot start sidekiq after 10 seconds"
false
rescue
false
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems