delayedjob fixes

This commit is contained in:
r888888888 2017-10-10 15:49:34 -07:00
parent c23ea7f7b2
commit c2029b62b5
3 changed files with 4 additions and 2 deletions

View File

@ -3,7 +3,7 @@ require 'delayed/plugin'
class DelayedJobTimeoutPlugin < ::Delayed::Plugin class DelayedJobTimeoutPlugin < ::Delayed::Plugin
callbacks do |lifecycle| callbacks do |lifecycle|
lifecycle.before(:execute) do |job| lifecycle.before(:execute) do |job|
job.class.connection.execute "set statement_timeout = 0" Delayed::Job.connection.execute "set statement_timeout = 0"
end end
end end
end end

View File

@ -5029,6 +5029,8 @@ CREATE INDEX index_comments_on_post_id ON comments USING btree (post_id);
-- --
CREATE INDEX index_delayed_jobs_on_run_at ON delayed_jobs USING btree (run_at); CREATE INDEX index_delayed_jobs_on_run_at ON delayed_jobs USING btree (run_at);
CREATE INDEX index_delayed_jobs_on_locked_by ON delayed_jobs USING btree (locked_by);
CREATE INDEX index_delayed_jobs_on_locked_at ON delayed_jobs USING btree (locked_at);
-- --

View File

@ -6,7 +6,7 @@ namespace :delayed_job do
within current_path do within current_path do
with rails_env: fetch(:rails_env) do with rails_env: fetch(:rails_env) do
hostname = capture("hostname").strip hostname = capture("hostname").strip
execute :bundle, "exec", "script/delayed_job", "--queues=default,#{hostname}", "-n 4", "start" execute :bundle, "exec", "script/delayed_job", "--queues=default,#{hostname}", "-n 2", "start"
end end
end end
end end