class Hasta::Env
Constructs the ENV variables required to run a local EMR job
Attributes
combined_storage[R]
files[R]
variables[R]
Public Class Methods
new( variables = {}, files = {}, combined_storage = Hasta.combined_storage )
click to toggle source
# File lib/hasta/env.rb, line 11 def initialize( variables = {}, files = {}, combined_storage = Hasta.combined_storage ) @variables = variables @files = files @combined_storage = combined_storage end
Public Instance Methods
setup()
click to toggle source
# File lib/hasta/env.rb, line 21 def setup file_vars = {} files.each do |key, s3_uri| input_source = S3DataSource.new(s3_uri, combined_storage) file_vars[key] = LocalFilePath.for(combined_storage.write(s3_uri, input_source)) end variables.merge(file_vars) end