Class: JobIteration::ParallelEnumerator::EnqueueJobs

Inherits:
Object
  • Object
show all
Defined in:
lib/job-iteration/parallel_enumerator.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(instances) ⇒ EnqueueJobs

Returns a new instance of EnqueueJobs.



10
11
12
 
# File 'lib/job-iteration/parallel_enumerator.rb', line 10

def initialize(instances)
  @instances = instances
end

Instance Attribute Details

#instances ⇒ Object (readonly)

Returns the value of attribute instances.



14
15
16
 
# File 'lib/job-iteration/parallel_enumerator.rb', line 14

def instances
  @instances
end

Instance Method Details

#enqueue_jobs(job) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/job-iteration/parallel_enumerator.rb', line 16

def enqueue_jobs(job)
  child_jobs = instances.times.map do |index|
    job.class.new(*job.arguments).tap do |child_job|
      child_job.cursor_position = { "instance" => index, "instances" => instances, "inner_cursor" => nil }

      # Carry forward potential overrides from the parent job
      child_job.queue_name = job.queue_name
      child_job.priority = job.priority if job.priority
    end
  end

  ActiveJob.perform_all_later(child_jobs)

  unless child_jobs.all?(&:successfully_enqueued?)
    failed_count = instances - child_jobs.count(&:successfully_enqueued?)
    raise EnqueueError, "Failed to enqueue #{failed_count} out of #{instances} child jobs"
  end
end