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.job_steps.each do |step|
          segment = step.crawl_segment
          segment.parse_time = DateTime.now
          segment.save
        end

        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.job_steps.each do |step|
          segment = step.crawl_segment
          segment.parse_time = DateTime.now
          segment.save
        end

        self.save
        self.result_message
      end
    end
Runs the job by calling Elastic MapReduce API.  If successful the
 parse time is set for each segment.