X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/62e3f155b14b30fde1323a367351c70b23f312b8..a603d0f7b685a93b88ea29336dd2b512e63b4508:/sdk/python/arvados/_normalize_stream.py diff --git a/sdk/python/arvados/_normalize_stream.py b/sdk/python/arvados/_normalize_stream.py index 4423639af7..babcabc1a7 100644 --- a/sdk/python/arvados/_normalize_stream.py +++ b/sdk/python/arvados/_normalize_stream.py @@ -1,3 +1,6 @@ +from __future__ import absolute_import +from . import config + def normalize_stream(stream_name, stream): """Take manifest stream and return a list of tokens in normalized format. @@ -9,12 +12,13 @@ def normalize_stream(stream_name, stream): """ + stream_name = stream_name.replace(' ', '\\040') stream_tokens = [stream_name] sortedfiles = list(stream.keys()) sortedfiles.sort() blocks = {} - streamoffset = 0L + streamoffset = 0 # Go through each file and add each referenced block exactly once. for streamfile in sortedfiles: for segment in stream[streamfile]: