def run
      emr_config = job_config['emr_config']
      job_flow_id = run_job_flow(emr_config)

      if job_flow_id.present?
        self.job_flow_id = job_flow_id
        self.save
        self.result_message
      end
    end
def run
      emr_config = job_config['emr_config']
      job_flow_id = run_job_flow(emr_config)

      if job_flow_id.present?
        self.job_flow_id = job_flow_id
        self.save
        self.result_message
      end
    end
Runs the job by calling the Elastic MapReduce API.