projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Retrieve manifest_text from API server. If that fails, emit a warning
[arvados.git]
/
sdk
/
python
/
arvados
/
stream.py
diff --git
a/sdk/python/arvados/stream.py
b/sdk/python/arvados/stream.py
index 8570b97c7cedae990f1e23bd2d17b4332f8583fa..0d0caee267b555790587d99f198d3fb461cb3faa 100644
(file)
--- a/
sdk/python/arvados/stream.py
+++ b/
sdk/python/arvados/stream.py
@@
-19,6
+19,8
@@
import time
import threading
from keep import *
import threading
from keep import *
+import config
+import errors
class StreamFileReader(object):
def __init__(self, stream, pos, size, name):
class StreamFileReader(object):
def __init__(self, stream, pos, size, name):
@@
-53,6
+55,9
@@
class StreamFileReader(object):
break
yield data
break
yield data
+ def seek(self, pos):
+ self._filepos = pos
+
def bunzip2(self, size):
decompressor = bz2.BZ2Decompressor()
for chunk in self.readall(size):
def bunzip2(self, size):
decompressor = bz2.BZ2Decompressor()
for chunk in self.readall(size):
@@
-99,7
+104,7
@@
class StreamFileReader(object):
def as_manifest(self):
if self.size() == 0:
return ("%s %s 0:0:%s\n"
def as_manifest(self):
if self.size() == 0:
return ("%s %s 0:0:%s\n"
- % (self._stream.name(), EMPTY_BLOCK_LOCATOR, self.name()))
+ % (self._stream.name(),
config.
EMPTY_BLOCK_LOCATOR, self.name()))
return string.join(self._stream.tokens_for_range(self._pos, self._size),
" ") + "\n"
return string.join(self._stream.tokens_for_range(self._pos, self._size),
" ") + "\n"