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