forked from e621ng/e621ng
[Cleanup] Remove remaining delayed jobs code
This commit is contained in:
parent
5a88be7d2d
commit
b37bb3c001
@ -1,7 +1 @@
|
||||
# class Delayed::Job
|
||||
# def hidden_attributes
|
||||
# [:handler]
|
||||
# end
|
||||
# end
|
||||
|
||||
Elasticsearch::Model::Response::Response.__send__ :include, Danbooru::Paginator::ElasticsearchExtensions
|
||||
|
@ -1,14 +0,0 @@
|
||||
# require 'delayed/plugin'
|
||||
#
|
||||
# class DelayedJobTimeoutPlugin < ::Delayed::Plugin
|
||||
# callbacks do |lifecycle|
|
||||
# lifecycle.before(:execute) do |job|
|
||||
# Delayed::Job.connection.execute "set statement_timeout = 0"
|
||||
# end
|
||||
# end
|
||||
# end
|
||||
#
|
||||
# Delayed::Worker.default_queue_name = "default"
|
||||
# Delayed::Worker.destroy_failed_jobs = false
|
||||
# Delayed::Worker.plugins << DelayedJobTimeoutPlugin
|
||||
# Delayed::Job.include(Danbooru::Paginator::ActiveRecordExtension)
|
@ -141,13 +141,6 @@ Rails.application.routes.draw do
|
||||
post :delete
|
||||
end
|
||||
end
|
||||
resources :delayed_jobs, :only => [:index, :destroy] do
|
||||
member do
|
||||
put :run
|
||||
put :retry
|
||||
put :cancel
|
||||
end
|
||||
end
|
||||
resources :dmails, :only => [:new, :create, :index, :show, :destroy] do
|
||||
collection do
|
||||
post :mark_all_as_read
|
||||
|
@ -2,7 +2,6 @@ require 'set'
|
||||
require 'timecop'
|
||||
|
||||
CurrentUser.ip_addr = "127.0.0.1"
|
||||
Delayed::Worker.delay_jobs = false
|
||||
$used_names = Set.new([""])
|
||||
|
||||
def rand_string(n, unique = false)
|
||||
|
@ -1,51 +0,0 @@
|
||||
namespace :delayed_job do
|
||||
desc "Start delayed_job process"
|
||||
task :start do
|
||||
on roles(:worker) do
|
||||
if test("[ -d #{current_path} ]")
|
||||
within current_path do
|
||||
with rails_env: fetch(:rails_env) do
|
||||
hostname = capture("hostname").strip
|
||||
execute :bundle, "exec", "script/delayed_job", "--queues=default,#{hostname}", "-n 8", "start"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Stop delayed_job process"
|
||||
task :stop do
|
||||
on roles(:worker) do
|
||||
if test("[ -d #{current_path} ]")
|
||||
within current_path do
|
||||
with rails_env: fetch(:rails_env) do
|
||||
execute :bundle, "exec", "script/delayed_job", "stop"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Restart delayed_job process"
|
||||
task :restart do
|
||||
on roles(:worker) do
|
||||
find_and_execute_task("delayed_job:stop")
|
||||
find_and_execute_task("delayed_job:start")
|
||||
end
|
||||
end
|
||||
|
||||
desc "Kill delayed_job process"
|
||||
task :kill do
|
||||
on roles(:worker) do
|
||||
procs = capture("ps -A -o pid,command").split(/\r\n|\r|\n/).grep(/delayed_job/).map(&:to_i)
|
||||
|
||||
if procs.any?
|
||||
execute "for i in #{procs.join(' ')} ; do kill -s TERM $i ; done"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
after "delayed_job:stop", "delayed_job:kill"
|
||||
before "deploy:started", "delayed_job:stop"
|
||||
after "deploy:published", "delayed_job:start"
|
@ -1,6 +0,0 @@
|
||||
#!/usr/bin/env ruby
|
||||
|
||||
require File.expand_path(File.join(File.dirname(__FILE__), '..', 'config', 'environment'))
|
||||
require 'delayed/command'
|
||||
Delayed::Job.connection.execute "set statement_timeout=0"
|
||||
Delayed::Command.new(ARGV).daemonize
|
Loading…
Reference in New Issue
Block a user