def run_job_flow(emr_config)
      cluster = Cluster.new
      job_flow = cluster.create_job_flow(self, emr_config)

      job_steps.each do |step|
        job_flow.add_step(step.job_flow_step(job_config))
      end

      begin
        job_flow.run

      rescue StandardError => e
        raise ElasticMapReduceAccessError, e.message
      end
    end
def run_job_flow(emr_config)
      cluster = Cluster.new
      job_flow = cluster.create_job_flow(self, emr_config)

      job_steps.each do |step|
        job_flow.add_step(step.job_flow_step(job_config))
      end

      begin
        job_flow.run

      rescue StandardError => e
        raise ElasticMapReduceAccessError, e.message
      end
    end
Calls the Elastic MapReduce API to create a Job Flow. Returns the Job Flow ID.