ActiveJob с адаптером Resque (добавить функцию задержки/тайм-аута)

Я планирую передать несколько активных заданий, используя цикл. Но мне нужно иметь функцию задержки/тайм-аута в каждом цикле данных. Мой код выглядит так:

for s in @saved_jobs
  # ADD delay funtion for each data to pass in ActiveJob Process
  # for ex. every data will pass to background job after every 3minutes
  ActiveCallsJob.perform_later(xxx, xx, x)
end

@saved_jobs = Information from DB
ActiveCallsJob = Class name of ActiveJob

Пожалуйста, помогите Спасибо!


person aldrien.h    schedule 30.06.2015    source источник


Ответы (1)


Это просто. Вам просто нужно прочитать руководство: http://guides.rubyonrails.org/active_job_basics.html#enqueue-the-job

# Enqueue a job to be performed tomorrow at noon.
MyJob.set(wait_until: Date.tomorrow.noon).perform_later(record)

# Enqueue a job to be performed 1 week from now.
MyJob.set(wait: 1.week).perform_later(record)
person Cristian Bica    schedule 20.08.2015