Stop resque workers through rake. Refs #543

lib/recipes/resque.rb

@@ -20,12 +20,15 @@ Capistrano::Configuration.instance(:must_exist).load do
     end
 
     def stop_workers
-      ps = 'ps aux | grep resque | grep -v grep'
-      run "#{ps} && kill -QUIT `#{ps} | awk '{ print $2 }'` || echo 'Workers already stopped!'"
+      # ps = 'ps aux | grep resque | grep -v grep'
+      # run "#{ps} && kill -QUIT `#{ps} | awk '{ print $2 }'` || echo 'Workers already stopped!'"
+      # run "kill -QUIT `ps aux | grep resque | grep -v grep | awk '{ print $2 }'`"
+      # run "kill -QUIT `ps aux | grep resque | grep -v grep | awk '{ print $2 }'` > /dev/null 2>&1 &"
+      run "cd #{fetch :current_path} && #{rails_env} bundle exec rake resque:stop_workers"
     end
 
     def start_workers
-      run "cd #{fetch :current_path} && COUNT=#{ workers_count } QUEUE=fork_import,hook,clone_build,notification #{ rails_env } BACKGROUND=yes bundle exec rake resque:workers"
+      run "cd #{fetch :current_path} && COUNT=#{workers_count} QUEUE=fork_import,hook,clone_build,notification #{rails_env} BACKGROUND=yes bundle exec rake resque:workers"
     end
   end
 end

lib/tasks/resque.rake

@@ -0,0 +1,10 @@
+namespace :resque do
+  desc 'Stop all Resque workers'
+  task :stop_workers => :environment do
+    pids = []
+    Resque.workers.each do |worker|
+      pids << worker.to_s.split(/:/).second
+    end
+    system("kill -QUIT #{pids.join(' ')}") if pids.size > 0
+  end
+end