mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
4cf7559280
Sometimes cascading association deletions can cause timeouts due to an IO issue. Perhaps a model has associations that are destroyed on deletion which in turn trigger other deletions and this can continue down a complex tree. Along this tree you may also hit other IO operations. Such deep deletions can lead to server timeouts while awaiting completion and really the user may not notice all the changes on their side immediately making them wait unnecesarially or worse causing a timeout during the operation. We now allow associations supporting the `dependent:` key to take `:destroy_async`, which schedules a background job to destroy associations. Co-authored-by: Adrianna Chang <adrianna.chang@shopify.com> Co-authored-by: Rafael Mendonça França <rafael@franca.dev> Co-authored-by: Cory Gwin @gwincr11 <gwincr11@github.com>
53 lines
1.5 KiB
Ruby
53 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "global_id/railtie"
|
|
require "active_job"
|
|
|
|
module ActiveJob
|
|
# = Active Job Railtie
|
|
class Railtie < Rails::Railtie # :nodoc:
|
|
config.active_job = ActiveSupport::OrderedOptions.new
|
|
config.active_job.custom_serializers = []
|
|
|
|
initializer "active_job.logger" do
|
|
ActiveSupport.on_load(:active_job) { self.logger = ::Rails.logger }
|
|
end
|
|
|
|
initializer "active_job.custom_serializers" do |app|
|
|
config.after_initialize do
|
|
custom_serializers = app.config.active_job.delete(:custom_serializers)
|
|
ActiveJob::Serializers.add_serializers custom_serializers
|
|
end
|
|
end
|
|
|
|
initializer "active_job.set_configs" do |app|
|
|
options = app.config.active_job
|
|
options.queue_adapter ||= :async
|
|
|
|
ActiveSupport.on_load(:active_job) do
|
|
options.each do |k, v|
|
|
k = "#{k}="
|
|
send(k, v) if respond_to? k
|
|
end
|
|
end
|
|
|
|
ActiveSupport.on_load(:action_dispatch_integration_test) do
|
|
include ActiveJob::TestHelper
|
|
end
|
|
|
|
ActiveSupport.on_load(:active_record) do
|
|
self.destroy_association_async_job = ActiveRecord::DestroyAssociationAsyncJob
|
|
end
|
|
end
|
|
|
|
initializer "active_job.set_reloader_hook" do |app|
|
|
ActiveSupport.on_load(:active_job) do
|
|
ActiveJob::Callbacks.singleton_class.set_callback(:execute, :around, prepend: true) do |_, inner|
|
|
app.reloader.wrap do
|
|
inner.call
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|