X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/62e3f155b14b30fde1323a367351c70b23f312b8..81fa59a1e7797da8d420a94216bd28031178ae51:/sdk/python/arvados/_normalize_stream.py diff --git a/sdk/python/arvados/_normalize_stream.py b/sdk/python/arvados/_normalize_stream.py index 4423639af7..47b66c82da 100644 --- a/sdk/python/arvados/_normalize_stream.py +++ b/sdk/python/arvados/_normalize_stream.py @@ -1,3 +1,10 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: Apache-2.0 + +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 +16,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]: