tumugi/tumugi

View on GitHub
examples/data_pipeline.rb

Summary

Maintainability
A
0 mins
Test Coverage
task :generate_data do
  output do
    target(:local_file, "tmp/tumugi_data_#{Time.now.strftime('%Y-%m-%d')}.txt")
  end

  run do
    output.open('w') do |f|
      (1..10).each do |i|
        f.puts i
      end
    end
  end
end

task :sum do
  requires :generate_data

  output do
    target(:local_file, "tmp/tumugi_output_#{Time.now.strftime('%Y-%m-%d')}.txt")
  end

  run do
    sum = 0
    input.open do |f|
      f.each_line do |line|
        sum += line.to_i
      end
    end
    output.open('w') { |f| f.puts(sum) }
  end
end