module ActiveJob::TestHelper
def assert_enqueued_with(args = {}, &_block)
end
MyJob.perform_later(1,2,3)
assert_enqueued_with(job: MyJob, args: [1,2,3], queue: 'low') do
def assert_enqueued_job
Asserts that the job passed in the block has been enqueued with the given arguments.
def assert_enqueued_with(args = {}, &_block) original_enqueued_jobs = enqueued_jobs.dup clear_enqueued_jobs args.assert_valid_keys(:job, :args, :at, :queue) yield matching_job = enqueued_jobs.any? do |job| args.all? { |key, value| value == job[key] } end assert matching_job, "No enqueued job found with #{args}" ensure queue_adapter.enqueued_jobs = original_enqueued_jobs + enqueued_jobs end