Merge remote-tracking branch 'origin/master' into 2061-update-docs

[arvados.git] / sdk / python / arvados / stream.py

diff --git a/sdk/python/arvados/stream.py b/sdk/python/arvados/stream.py
index 5dd8a89eefc923f93d0c83fb27d82bc74a9bbcaf..0d0caee267b555790587d99f198d3fb461cb3faa 100644 (file)
--- a/sdk/python/arvados/stream.py
+++ b/sdk/python/arvados/stream.py
@@ -18,6 +18,10 @@ import fcntl
 import time
 import threading
 
+from keep import *
+import config
+import errors
+
 class StreamFileReader(object):
     def __init__(self, stream, pos, size, name):
         self._stream = stream
@@ -51,6 +55,9 @@ class StreamFileReader(object):
                 break
             yield data
 
+    def seek(self, pos):
+        self._filepos = pos
+
     def bunzip2(self, size):
         decompressor = bz2.BZ2Decompressor()
         for chunk in self.readall(size):
@@ -97,7 +104,7 @@ class StreamFileReader(object):
     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"