Sha256: 482667721c4adae28787c378112317b6a952eb4e0f0388ffb36702d5f3d7952f
Contents?: true
Size: 1.29 KB
Versions: 28
Compression:
Stored size: 1.29 KB
Contents
# configuration variables
_cset(:delayed_job_workers, {})
# these cannot be overriden
set(:delayed_job_script) { File.join(bin_path, "delayed_job") }
after "deploy:update_code", "delayed_job:setup"
after "deploy:restart", "delayed_job:restart"
monit_config "delayed_job", <<EOF, :roles => :worker
<% delayed_job_workers.each do |name, range| %>
check process delayed_job_<%= name %>
with pidfile <%= pid_path %>/delayed_job.<%= name %>.pid
<% if range.nil? %>
start program = "<%= delayed_job_script %> start <%= name %>"
stop program = "<%= delayed_job_script %> stop <%= name %>"
<% else %>
start program = "<%= delayed_job_script %> start <%= name %> <%= range.begin %> <%= range.end %>"
stop program = "<%= delayed_job_script %> stop <%= name %> <%= range.begin %> <%= range.end %>"
<% end %>
group delayed_job
<% end %>
EOF
namespace :delayed_job do
desc "Generate DelayedJob configuration files"
task :setup, :roles => :worker, :except => { :no_release => true } do
upload_template_file("delayed_job.sh",
delayed_job_script,
:mode => "0755")
end
desc "Restart DelayedJob workers"
task :restart, :roles => :worker, :except => { :no_release => true } do
if fetch(:monitrc, false)
run "monit -g delayed_job restart all"
fi
end
end
Version data entries
28 entries across 28 versions & 1 rubygems