module Waluigi::TaskDefinitionHelper

Public Instance Methods

build(*args, **kwargs) click to toggle source
# File lib/waluigi/helpers.rb, line 60
def build(*args, **kwargs)
        RubyTaskRequirement.new(name, args, kwargs)
end
defined_outputs() click to toggle source
# File lib/waluigi/helpers.rb, line 25
def defined_outputs
        @ctx.outputs
end
defined_parameters() click to toggle source
# File lib/waluigi/helpers.rb, line 33
def defined_parameters
        @ctx.parameters.map do |param|
                if param.is_a? RubyTaskParameter
                        t = if param.type
                                param.type 
                        else 
                                Python::Luigi.Parameter 
                        end
                        [param.name, t.new(**param.kwargs)]
                else
                        [param.name, param]
                end
        end
end
defined_requirements() click to toggle source
# File lib/waluigi/helpers.rb, line 48
def defined_requirements
        @ctx.requirements.map do |req|
                if req.is_a? RubyTaskRequirement
                        req.build
                elsif req.included_modules.include? Waluigi::Task # FIXME
                        RubyTaskRequirement.new(req.name).build
                else
                        req
                end
        end
end
output(o) click to toggle source
# File lib/waluigi/helpers.rb, line 17
def output(o)
        @ctx.outputs << o
end
parameter(name, type:nil, **kwargs) click to toggle source
# File lib/waluigi/helpers.rb, line 29
def parameter(name, type:nil, **kwargs)
        @ctx.parameters << RubyTaskParameter.new(name, type, kwargs)
end
requires(r) click to toggle source
# File lib/waluigi/helpers.rb, line 21
def requires(r)
        @ctx.requirements << r
end