diff options
Diffstat (limited to 'config/initializers/forbid_sidekiq_in_transactions.rb')
-rw-r--r-- | config/initializers/forbid_sidekiq_in_transactions.rb | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/config/initializers/forbid_sidekiq_in_transactions.rb b/config/initializers/forbid_sidekiq_in_transactions.rb new file mode 100644 index 00000000000..4eeb4ba4468 --- /dev/null +++ b/config/initializers/forbid_sidekiq_in_transactions.rb @@ -0,0 +1,27 @@ +module Sidekiq + module Worker + module ClassMethods + module NoSchedulingFromTransactions + NESTING = ::Rails.env.test? ? 1 : 0 + + %i(perform_async perform_at perform_in).each do |name| + define_method(name) do |*args| + if ActiveRecord::Base.connection.open_transactions > NESTING + raise <<-MSG.strip_heredoc + `#{self}.#{name}` cannot be called inside a transaction as this can lead to race + conditions when the worker runs before the transaction is committed and tries to + access a model that has not been saved yet. + + Schedule the worker from inside a `run_after_commit` block instead. + MSG + end + + super(*args) + end + end + end + + prepend NoSchedulingFromTransactions + end + end +end |