lib/emr/right_emr_interface.rb
# Adds steps to a running job flow.
#
# A maximum of 256 steps are allowed in a job flow. Steps can only be
# added to job flows that are starting, bootstrapping, running or waiting.
#
# Step configuration options are the same as the ones accepted by
# run_job_flow.
#
#  emr.add_job_flow_steps('j-2QE0KHA1LP4GS', {
#    :name => 'step 1',
#    :jar => 's3n://bucket/path/to/code.jar',
#    :main_class => 'com.foobar.emr.Step1',
#    :args => ['arg', 'arg'],
#    :properties => {
#      'property' => 'value',
#    },
#    :action_on_failure => 'TERMINATE_JOB_FLOW',
#  }) #=> true
#
Adds steps to a running job flow.
A maximum of 256 steps are allowed in a job flow. Steps can only be
added to job flows that are starting, bootstrapping, running or waiting.

Step configuration options are the same as the ones accepted by
run_job_flow.


Adds steps to a running job flow . A maximum of 256 steps are allowed in a job flow . Steps can only be added to job flows that are starting bootstrapping running or waiting . Step configuration options are the same as the ones accepted by run_job_flow .
def add_job_flow_steps(job_flow_id, *steps)
      request_hash = amazonize_steps(steps)
      request_hash['JobFlowId'] = job_flow_id
      link = generate_request("AddJobFlowSteps", request_hash)
      request_info(link, RightHttp2xxParser.new(:logger => @logger))
    rescue
      on_exception
    end
def add_job_flow_steps ( job_flow_id , * steps ) request_hash = amazonize_steps ( steps ) request_hash [ 'JobFlowId' ] = job_flow_id link = generate_request ( "AddJobFlowSteps" , request_hash ) request_info ( link , RightHttp2xxParser . new ( :logger => @logger ) ) rescue on_exception end
Adds steps to a running job flow.
Adds steps to a running job flow .
job_flow_id
<not_specific>
steps
<not_specific>