GG
Size: a a a
GG
GG
GG
GG
A
A
A
A
GG
GG
A
GG
A
A
GG
A
A
A
desc "Start Resque workers"
task :start do
for_each_workers do |role, workers|
on roles(role) do
create_pid_path
worker_id = 1
workers.each_pair do |queue, number_of_workers|
info "Starting #{number_of_workers} worker(s) with QUEUE: #{queue}"
number_of_workers.times do
pid = "#{fetch(:resque_pid_path)}/resque_work_#{worker_id}.pid"
within current_path do
execute :nohup, %{#{SSHKit.config.command_map[:rake]} RACK_ENV=#{rails_env} RAILS_ENV=#{rails_env} #{fetch(:resque_extra_env)} QUEUE="#{queue}" PIDFILE=#{pid} BACKGROUND=yes #{"VERBOSE=1 " if fetch(:resque_verbose)}INTERVAL=#{fetch(:interval)} #{"environment " if fetch(:resque_environment_task)}resque:work #{output_redirection}}
end
worker_id += 1
end
end
end
end
end
bundle exec rake COUNT=5 QUEUE=sms PIDFILE=tmp/pids/resque.pid BACKGROUND=yes INTERVAL=5 resque:workers
GG
DG