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