def _job_state_from_batches(self, job_id):
    uri = '{}/job/{}/batch'.format(self.bulk.endpoint, job_id)
    response = requests.get(uri, headers=self.bulk.headers())
    return self._parse_job_state(response.content)
def _job_state_from_batches(self, job_id):
    uri = '{}/job/{}/batch'.format(self.bulk.endpoint, job_id)
    response = requests.get(uri, headers=self.bulk.headers())
    return self._parse_job_state(response.content)