Module: Sidekiq::DelayedTestingExtensions

Includes:
TestingExtensions
Included in:
Sidekiq::DelayExtensions::DelayedMailer, Sidekiq::DelayExtensions::DelayedModel
Defined in:
lib/sidekiq/delay_extensions/testing.rb

Instance Method Summary collapse

Instance Method Details

#jobs_for(klass, unsafe_load: false) ⇒ Object

NOTE(BF): Extend Sidekiq::TestingExtensions to optionally handle unsafely loading YAML for delayed extensions in Sidekiq 7.x.



12
13
14
15
16
17
18
19
 
# File 'lib/sidekiq/delay_extensions/testing.rb', line 12

def jobs_for(klass, unsafe_load: false)
  return super(klass) unless unsafe_load
  jobs.select do |job|
    marshalled = job["args"][0]
    next unless marshalled.index(klass.to_s)
    ::Sidekiq::DelayExtensions::YAML.unsafe_load(marshalled)
  end
end