module ActiveJob::TestHelper

def instantiate_job(payload)
  args = ActiveJob::Arguments.deserialize(payload[:args])
  job = payload[:job].new(*args)
  job.scheduled_at = Time.at(payload[:at]) if payload.key?(:at)
  job.queue_name = payload[:queue]
  job
end