job_flow.rb in elasticity-4.0.4

- old
+ new

@@ -20,10 +20,11 @@
     attr_accessor :ec2_subnet_id
     attr_accessor :placement
     attr_accessor :region
     attr_accessor :visible_to_all_users
     attr_accessor :enable_debugging
+    attr_accessor :job_flow_role
 
     attr_reader :access_key
     attr_reader :secret_key
 
     def initialize(access=nil, secret=nil)
@@ -183,10 +184,11 @@
       config = jobflow_preamble
       steps = jobflow_steps
       steps.insert(0, Elasticity::SetupHadoopDebuggingStep.new.to_aws_step(self)) if @enable_debugging
       config[:steps] = steps
       config[:log_uri] = @log_uri if @log_uri
+      config[:job_flow_role] = @job_flow_role if @job_flow_role
       config[:bootstrap_actions] = @bootstrap_actions.map{|a| a.to_aws_bootstrap_action} unless @bootstrap_actions.empty?
       config
     end
 
     def jobflow_preamble
@@ -227,6 +229,6 @@
       groups.map(&:to_aws_instance_config)
     end
 
   end
 
-end
\ No newline at end of file
+end