X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/62e3f155b14b30fde1323a367351c70b23f312b8..9e3fd2fa437e2f3dab220a96fbe22ec5b250421d:/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]: