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