Sha256: 47e9594cb3d922a51f870ebe0e4d703d1ad39d3801e1cc6ccaeccb705ea58b32
Contents?: true
Size: 1.76 KB
Versions: 7
Compression:
Stored size: 1.76 KB
Contents
#########
## Adds support to monitor delayed_job processes through eye
#########
# Watch the delayed_job processes using the build in template
namespace :delayed_job do
# Remove the multi process arg
def delayed_job_single_args
delayed_job_args.gsub(/-n\s\d\s*/, "")
end
def delayed_job_start_command
"#{fetch(:rbenv_prefix)} bundle exec #{delayed_job_bin} #{delayed_job_single_args} -i \#{i} start"
end
def delayed_job_stop_command
"#{fetch(:rbenv_prefix)} bundle exec #{delayed_job_bin} #{delayed_job_single_args} -i \#{i} stop"
end
task :watch_process do
watch_process(:delayed_job, start_command: delayed_job_start_command,
stop_command: delayed_job_stop_command,
start_timeout: fetch(:eye_delayed_job_start_timeout, 60),
stop_timeout: fetch(:eye_delayed_job_stop_timeout, 30),
restart_timeout: fetch(:eye_delayed_job_restart_timeout, 30),
start_grace: fetch(:eye_delayed_job_start_grace, 100),
stop_grace: fetch(:eye_delayed_job_stop_grace, 30),
restart_grace: fetch(:eye_delayed_job_restart_grace, 30),
workers: fetch(:delayed_job_workers, 1)
)
end
# Override start, restart and stop delayed_job tasks to so they call
# the eye equivalents
['start', 'restart', 'stop'].each do |cmd|
if Rake::Task.task_defined?("delayed_job:#{cmd}")
Rake::Task["delayed_job:#{cmd}"].clear_actions
# Reload or restart delayed_job after the application is published
desc "using eye"
task cmd do
invoke "eye:#{cmd}", 'delayed-job'
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems