Class: StepperMotor::ForwardScheduler

Inherits:
Object
  • Object
show all
Defined in:
lib/stepper_motor/forward_scheduler.rb

Overview

The forward scheduler enqueues a job for every Journey that gets sent to the #schedule. The job is then stored in the queue and gets picked up by the ActiveJob worker normally. This is the simplest option if your ActiveJob adapter supports far-ahead scheduling. Some adapters, such as SQS, have limitations regarding the maximum delay after which a message will become visible. For SQS, the limit is 900 seconds. If the job is further in the future, it is likely going to fail to get enqueued. If you are working with a queue adapter either:

  • Does not allow easy introspection of jobs in the future (like Redis-based queues)
  • Limits the value of the wait: parameter

this scheduler is not a good fit for you, and you will need to use the CyclicScheduler instead.

Direct Known Subclasses

CyclicScheduler

Instance Method Summary collapse

Instance Method Details

#schedule(journey) ⇒ Object 



15
16
17
18
19
 
# File 'lib/stepper_motor/forward_scheduler.rb', line 15

def schedule(journey)
  wait = journey.next_step_to_be_performed_at - Time.current
  wait = 0 if wait.negative?
  StepperMotor::PerformStepJob.set(wait: wait).perform_later(journey.to_global_id.to_s)
end