Module: ActiveJob::Temporal::WorkflowEnqueuerBatch

Included in:
WorkflowEnqueuer
Defined in:
lib/activejob/temporal/workflow_enqueuer_batch.rb

Instance Method Summary collapse

Instance Method Details

#enqueue_batch(items, concurrency: 1) ⇒ Object 



8
9
10
11
12
13
14
 
# File 'lib/activejob/temporal/workflow_enqueuer_batch.rb', line 8

def enqueue_batch(items, concurrency: 1)
  BatchEnqueuer.new(
    enqueue: method(:enqueue),
    validate_job: method(:validate_job_for_enqueueing),
    validate_scheduled_at: method(:validate_scheduled_at!)
  ).enqueue(items, concurrency: concurrency)
end