Contents

module Wukong

  class Dataflow < Hanuman::Tree
    def self.configure(settings)
      settings.description = builder.description if builder.description
    end
  end
  
  class DataflowBuilder < Hanuman::TreeBuilder

    def description desc=nil
      @description = desc if desc
      @description
    end
    
    def namespace() Wukong::Dataflow ; end

    def handle_dsl_arguments_for(stage, *args, &action)
      options = args.extract_options!
      while stages.include?(stage.label)
        parts = stage.label.to_s.split('_')
        if parts.last.to_i > 0
          parts[-1] = parts.last.to_i + 1
        else
          parts.push(1)
        end
        stage.label = parts.map(&:to_s).join('_').to_sym
      end
      stage.merge!(options.merge(action: action).compact)
      stage.graph = self
      stage
    end
  
    def method_missing(name, *args, &blk)
      if stages[name]
        handle_dsl_arguments_for(stages[name], *args, &blk)
      else
        super
      end
    end
    
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
ul-wukong-4.1.0	lib/wukong/dataflow.rb
wukong-4.0.0	lib/wukong/dataflow.rb