3bcc503cf7
Add a dedicated queue for bulk update requests and process it using a single worker. This prevents bulk updates from consuming all available workers and preventing other job types from running. This also effectively serializes bulk updates so that they're processed one-at-a-time instead of in parallel. This will be slower overall but may avoid some of the issues with indeterminate update order under parallel updates.
40 lines
1.3 KiB
Ruby
40 lines
1.3 KiB
Ruby
namespace :delayed_job do
|
|
desc "Start delayed_job process"
|
|
task :start do
|
|
on roles(:worker) do
|
|
within current_path do
|
|
with rails_env: fetch(:rails_env) do
|
|
execute :"systemd-run", "--user --collect --slice delayed_job --unit delayed_job.bulk_update -E RAILS_ENV=$RAILS_ENV -p WorkingDirectory=$PWD -p Restart=always #{bundle} exec script/delayed_job --queues=bulk_update run"
|
|
|
|
fetch(:delayed_job_workers, 16).times do |n|
|
|
bundle = SSHKit.config.command_map[:bundle]
|
|
execute :"systemd-run", "--user --collect --slice delayed_job --unit delayed_job.#{n} -E RAILS_ENV=$RAILS_ENV -p WorkingDirectory=$PWD -p Restart=always #{bundle} exec script/delayed_job --queues=default run"
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "Stop delayed_job process"
|
|
task :stop do
|
|
on roles(:worker) do
|
|
execute :systemctl, "--user stop delayed_job.slice"
|
|
end
|
|
end
|
|
|
|
desc "Restart delayed_job process"
|
|
task :restart do
|
|
on roles(:worker) do
|
|
execute :systemctl, "--user restart delayed_job.slice"
|
|
end
|
|
end
|
|
|
|
desc "Show status of delayed_job process"
|
|
task :status do
|
|
on roles(:worker) do
|
|
# systemctl exits with status 3 if the service isn't running.
|
|
execute :systemctl, "--user status delayed_job.slice", raise_on_non_zero_exit: false
|
|
end
|
|
end
|
|
end
|