@ndb.tasklet
  def _get_segment(self, start, request_size):
    end = start + request_size - 1
    content_range = '%d-%d' % (start, end)
    headers = {'Range': 'bytes=' + content_range}
    status, resp_headers, content = yield self._api.get_object_async(
        self.name, headers=headers)
    errors.check_status(status, [200, 206], self.name, headers, resp_headers)
    self._check_etag(resp_headers.get('etag'))
    raise ndb.Return(content)
Diagonals are connected, so feature is retained
dataset/ETHPy150Open GoogleCloudPlatform/billing-export-python/cloudstorage/storage_api.py/ReadBuffer._get_segment--crossover with--dataset/ETHPy150Open mapbox/rasterio/tests/test_features.py/test_sieve_connectivity_queen