code: def get_outputs(self):
      
      assert self.SUCCESS == self.get_status()
      ss = model.ShardState.find_all_by_mapreduce_state(self._state)
      for s in ss:
        yield iter(s.writer_state.get("outs", []))
docs: Get outputs of this job.
  
      Should only call if status is SUCCESS.
  
      Yields:
        Iterators, one for each shard. Each iterator is
        from the argument of map_job.output_writer.commit_output.