module SidekiqWorkflows::Node
Public Instance Methods
add_group(workers)
click to toggle source
# File lib/sidekiq_workflows/node.rb, line 3 def add_group(workers) @children << (child = WorkerNode.new(workers: workers, workflow_uuid: workflow_uuid, on_partial_complete: on_partial_complete, parent: self)) child end
all_nodes()
click to toggle source
# File lib/sidekiq_workflows/node.rb, line 12 def all_nodes [self] + children.flat_map(&:all_nodes) end
serialize()
click to toggle source
# File lib/sidekiq_workflows/node.rb, line 8 def serialize to_h.to_json end