X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1e3aba5a02acd7670a4525ba9c0ce53b7e7e12de..00af5ad16232b856ef1f3620a4f62f0946c681a7:/sdk/python/arvados/stream.py

diff --git a/sdk/python/arvados/stream.py b/sdk/python/arvados/stream.py
index 8570b97c7c..0d0caee267 100644
--- a/sdk/python/arvados/stream.py
+++ b/sdk/python/arvados/stream.py
@@ -19,6 +19,8 @@ import time
 import threading
 
 from keep import *
+import config
+import errors
 
 class StreamFileReader(object):
     def __init__(self, stream, pos, size, name):
@@ -53,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):
@@ -99,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"