Method: ActiveJob::QueueAdapters::AsyncAdapter::Scheduler#enqueue_at

Defined in:
activejob/lib/active_job/queue_adapters/async_adapter.rb

#enqueue_at(job, timestamp, queue_name:) ⇒ Object 



96
97
98
99
100
101
102
103
 
# File 'activejob/lib/active_job/queue_adapters/async_adapter.rb', line 96

def enqueue_at(job, timestamp, queue_name:)
  delay = timestamp - Time.current.to_f
  if !immediate && delay > 0
    Concurrent::ScheduledTask.execute(delay, args: [job], executor: executor, &:perform)
  else
    enqueue(job, queue_name: queue_name)
  end
end