Проверьте наличие файла PID демонов (File.exist? ...). Если он там, то предположите, что он работает, иначе запустите его.

Еще несколько идей по очистке: "Начало" не нужно. Вы должны спасти «нет такого процесса», чтобы не запускать новые процессы, когда что-то еще пойдет не так. Спасите «нет такого файла или каталога», чтобы упростить условие.

DELAYED_JOB_PID_PATH = "#{Rails.root}/tmp/pids/delayed_job.pid"

def start_delayed_job
  Thread.new do 
    `ruby script/delayed_job start`
  end
end

def daemon_is_running?
  pid = File.read(DELAYED_JOB_PID_PATH).strip
  Process.kill(0, pid.to_i)
  true
rescue Errno::ENOENT, Errno::ESRCH   # file or process not found
  false
end

start_delayed_job unless daemon_is_running?

Имейте в виду, что этот код не будет работать, если вы запустите более одного воркера. И проверьте аргумент «-m» сценария / delayed_job, который запускает процесс монитора вместе с демоном (ами).

Спасибо за решение, представленное в вопросе (и ответ, который вдохновил его :-)), оно работает для меня, даже с несколькими рабочими (Rails 3.2.9, Ruby 1.9.3p327).

Меня беспокоит, что я могу забыть перезапустить delayed_job, например, после некоторых изменений в lib, что заставит меня часами отлаживать, прежде чем я это осознаю.

Я добавил следующее в свой script/rails файл, чтобы код, указанный в вопросе, выполнялся каждый раз, когда мы запускаем rails, но не каждый раз, когда запускается рабочий:

puts "cleaning up delayed job pid..."
dj_pid_path = File.expand_path('../../tmp/pids/delayed_job.pid',  __FILE__)
begin
  File.delete(dj_pid_path)
rescue Errno::ENOENT # file does not exist
end
puts "delayed_job ready."

Небольшой недостаток, с которым я столкнулся с этим, заключается в том, что он также вызывается, например, с помощью rails generate. Я не тратил много времени на поиски решения для этого, но предложения приветствуются :-)

Обратите внимание: если вы используете единорога, вы можете добавить тот же код в config/unicorn.rb перед вызовом before_fork.

- ИЗМЕНИТЬ: немного поэкспериментировав с приведенными выше решениями, я сделал следующее:

Я создал файл script/start_delayed_job.rb с содержанием:

puts "cleaning up delayed job pid..."
dj_pid_path = File.expand_path('../../tmp/pids/delayed_job.pid',  __FILE__)

def kill_delayed(path)
  begin
    pid = File.read(path).strip
    Process.kill(0, pid.to_i)
    false
  rescue
    true
  end
end

kill_delayed(dj_pid_path)

begin
  File.delete(dj_pid_path)
rescue Errno::ENOENT # file does not exist
end

# spawn delayed
env = ARGV[1]
puts "spawing delayed job in the same env: #{env}" 

# edited, next line has been replaced with the following on in order to ensure delayed job is running in the same environment as the one that spawned it
#Process.spawn("ruby script/delayed_job start")
system({ "RAILS_ENV" => env}, "ruby script/delayed_job start")

puts "delayed_job ready."

Теперь я могу потребовать этот файл где угодно, включая 'script / rails' и 'config / unicorn.rb', выполнив:

# in top of script/rails
START_DELAYED_PATH = File.expand_path('../start_delayed_job',  __FILE__)
require "#{START_DELAYED_PATH}"

# in config/unicorn.rb, before before_fork, different expand_path
START_DELAYED_PATH = File.expand_path('../../script/start_delayed_job',  __FILE__)
require "#{START_DELAYED_PATH}"

не отлично, но работает

отказ от ответственности: я говорю не очень хорошо, потому что это вызывает периодический перезапуск, что для многих нежелательно. И простая попытка запуска может вызвать проблемы, потому что реализация DJ может заблокировать очередь, если будут созданы повторяющиеся экземпляры.

Вы можете запланировать cron задачи, которые периодически запускаются для запуска рассматриваемых заданий. Поскольку DJ рассматривает команды запуска как запретные операции, когда задание уже выполняется, он просто работает. Этот подход также учитывает случай, когда DJ умирает по какой-либо причине, кроме перезапуска хоста.

# crontab example 
0 * * * * /bin/bash -l -c 'cd /var/your-app/releases/20151207224034 && RAILS_ENV=production bundle exec script/delayed_job --queue=default -i=1 restart'

Если вы используете такой драгоценный камень, как whenever, это довольно просто.

every 1.hour do
  script "delayed_job --queue=default -i=1 restart"
  script "delayed_job --queue=lowpri -i=2 restart"
end