X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/ad69b48e324c3ce29a4d2c84732dfd3d0288ebb3..f78b9c586f9ffa9846d68d35a10396261691da41:/sdk/python/arvados/stream.py diff --git a/sdk/python/arvados/stream.py b/sdk/python/arvados/stream.py index 85c0320119..3a42aa0101 100644 --- a/sdk/python/arvados/stream.py +++ b/sdk/python/arvados/stream.py @@ -62,13 +62,10 @@ class StreamReader(object): def all_files(self): return self._files.values() - def _size(self): + def size(self): n = self._data_locators[-1] return n.range_start + n.range_size - def size(self): - return self._size() - def locators_and_ranges(self, range_start, range_size): return locators_and_ranges(self._data_locators, range_start, range_size) @@ -78,10 +75,6 @@ class StreamReader(object): @retry_method def readfrom(self, start, size, num_retries=None): - return self._readfrom(start, size, num_retries=num_retries) - - @retry_method - def _readfrom(self, start, size, num_retries=None): """Read up to 'size' bytes from the stream, starting at 'start'""" if size == 0: return ''