collection.py import stream

diff --git a/sdk/python/arvados/collection.py b/sdk/python/arvados/collection.py
index 682bbf0509f35b079a21ce813cab0b0743121357..9a680d4033f1c73a9d75c947d5b50cdc6b3bfd6c 100644 (file)
--- a/sdk/python/arvados/collection.py
+++ b/sdk/python/arvados/collection.py
@@ -18,6 +18,8 @@ import fcntl
 import time
 import threading
 
+from stream import *
+
 class CollectionReader(object):
     def __init__(self, manifest_locator_or_text):
         if re.search(r'^\S+( [a-f0-9]{32,}(\+\S+)*)+( \d+:\d+:\S+)+\n', manifest_locator_or_text):