Class: Dwf::Callback

Inherits:
Object
  • Object
show all
Defined in:
lib/dwf/callback.rb

Constant Summary collapse

DEFAULT_KEY = 
'default_key'

Instance Method Summary collapse

Instance Method Details

#process_next_step(status, options) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/dwf/callback.rb', line 8

def process_next_step(status, options)
  previous_job_names = options['names']
  workflow_id = options['workflow_id']
  processing_job_names = previous_job_names.map do |job_name|
    node = client.find_node(job_name, workflow_id)
    node.outgoing
  end.flatten.uniq
  return if processing_job_names.empty?

  overall = Sidekiq::Batch.new(status.parent_bid)
  overall.jobs { setup_batches(processing_job_names, workflow_id) }
end

#start(job) ⇒ Object 



21
22
23
 
# File 'lib/dwf/callback.rb', line 21

def start(job)
  job.outgoing.any? ? start_with_batch(job) : job.persist_and_perform_async!
end