def _get_results(self, batch_id, job_id):
    result_ids = self.bulk.get_query_batch_result_ids(batch_id, job_id=job_id)
    for result_id in result_ids:
        self.logger.info('Result id: {}'.format(result_id))
        uri = '{}/job/{}/batch/{}/result/{}'.format(self.bulk.endpoint, job_id, batch_id, result_id)
        with _download_file(uri, self.bulk) as f:
            self.logger.info('Result {} downloaded'.format(result_id))
            (yield f)
def _get_results(self, batch_id, job_id):
    result_ids = self.bulk.get_query_batch_result_ids(batch_id, job_id=job_id)
    for result_id in result_ids:
        self.logger.info('Result id: {}'.format(result_id))
        uri = '{}/job/{}/batch/{}/result/{}'.format(self.bulk.endpoint, job_id, batch_id, result_id)
        with _download_file(uri, self.bulk) as f:
            self.logger.info('Result {} downloaded'.format(result_id))
            (yield f)