Sha256: 41495c1781cbbfda45f5d9f48ae9d770ce871f95d2ca812e876ade1ee59dfdc7
Contents?: true
Size: 1.8 KB
Versions: 8
Compression:
Stored size: 1.8 KB
Contents
namespace :rubber do
namespace :delayed_job do
rubber.allow_optional_tasks(self)
after "deploy:stop", "rubber:delayed_job:stop"
after "deploy:start", "rubber:delayed_job:start"
after "deploy:restart", "rubber:delayed_job:restart"
def args
rubber_env.delayed_job_args || "-n #{rubber_env.num_delayed_job_workers}"
end
desc "Stop the delayed_job process"
task :stop, :roles => :delayed_job do
rsudo "cd #{current_path} && RAILS_ENV=#{Rubber.env} script/delayed_job stop #{self.args}", :as => rubber_env.app_user
end
desc "Start the delayed_job process"
task :start, :roles => :delayed_job do
rsudo "cd #{current_path} && RAILS_ENV=#{Rubber.env} script/delayed_job start #{self.args}", :as => rubber_env.app_user
end
desc "Restart the delayed_job process"
task :restart, :roles => :delayed_job do
rsudo "cd #{current_path} && RAILS_ENV=#{Rubber.env} script/delayed_job restart #{self.args}", :as => rubber_env.app_user
end
desc "Live tail of delayed_job log files for all machines"
task :tail_logs, :roles => :delayed_job do
last_host = ""
log_file_glob = rubber.get_env("FILE", "Log files to tail", true, "#{current_path}/log/delayed_job.log")
trap("INT") { puts 'Exiting...'; exit 0; } # handle ctrl-c gracefully
run "tail -qf #{log_file_glob}" do |channel, stream, data|
puts if channel[:host] != last_host # blank line between different hosts
host = "[#{channel.properties[:host].gsub(/\..*/, '')}]" # get left-most subdomain
data.lines { |line| puts "%-15s %s" % [host, line] } # add host name to the start of each line
last_host = channel[:host]
break if stream == :err
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems