Contents

require File.dirname(__FILE__) + '/base' unless defined?(Capper)

require 'capper/bundler'
require 'capper/monit'

Capper.load do
  # configuration variables
  _cset(:delayed_job_workers, {})

  # these cannot be overriden
  set(:delayed_job_script) { File.join(bin_path, "delayed_job") }

  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, :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
      run "monit -g delayed_job restart all"
    end
  end

  after "deploy:update_code", "delayed_job:setup"
  after "deploy:restart", "delayed_job:restart"
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
capper-0.7.3	lib/capper/delayed_job.rb
capper-0.7.2	lib/capper/delayed_job.rb
capper-0.7.1	lib/capper/delayed_job.rb
capper-0.7.0	lib/capper/delayed_job.rb