module Pallets::DSL::Workflow

Public Instance Methods

task(arg=nil, as: nil, depends_on: nil, max_failures: nil, **kwargs) click to toggle source
# File lib/pallets/dsl/workflow.rb, line 4
def task(arg=nil, as: nil, depends_on: nil, max_failures: nil, **kwargs)
  # Have to work more to keep Pallets' nice DSL valid in Ruby 2.7
  arg = !kwargs.empty? ? kwargs : arg
  raise ArgumentError, 'Task is incorrectly defined. It must receive '\
                       'either a name, or a name => dependencies pair as '\
                       'the first argument' unless arg

  klass, dependencies = case arg
  when Hash
    # The `task Foo => Bar` notation
    arg.first
  else
    # The `task Foo, depends_on: Bar` notation
    [arg, depends_on]
  end

  task_class = klass.to_s
  as ||= task_class

  dependencies = Array(dependencies).compact.uniq.map(&:to_s)
  graph.add(as, dependencies)

  task_config[as] = {
    'workflow_class' => self.name,
    'task_class' => task_class,
    'max_failures' => max_failures || Pallets.configuration.max_failures
  }

  nil
end