Reschedule job in current queue

[iamtheschmitzer]

Inside my Faktory::Job, am attempting to reschedule the current job (same options) in the future.

  def reschedule_job(options)
    self.class.perform_in(RESCHEDULE_DELAY_DURATION, options)
  end

But this reschedules in the default queue. I would like to reschedule in the same queue if possible, but I haven't found out how to determine the current queue (my job could be enqueued in multiple queues).

Is there a way for my job to know queue that the job was dequeued from?

Thanks In advance

[mperham]

Jobs, by design, only have access to their arguments. You’d need to pass in the queue as an argument.