X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/7d4da75d3980d465053c44b4d5b16afe166912a6..187f790d8b71c5c7b54a599bec6e58950d7116dc:/sdk/python/arvados/_normalize_stream.py diff --git a/sdk/python/arvados/_normalize_stream.py b/sdk/python/arvados/_normalize_stream.py index b579d41ed2..c72b82be1c 100644 --- a/sdk/python/arvados/_normalize_stream.py +++ b/sdk/python/arvados/_normalize_stream.py @@ -8,9 +8,7 @@ from . import config import re def escape(path): - path = re.sub('\\\\', lambda m: '\\134', path) - path = re.sub('[:\000-\040]', lambda m: "\\%03o" % ord(m.group(0)), path) - return path + return re.sub(r'[\\:\000-\040]', lambda m: "\\%03o" % ord(m.group(0)), path) def normalize_stream(stream_name, stream): """Take manifest stream and return a list of tokens in normalized format. @@ -55,13 +53,13 @@ def normalize_stream(stream_name, stream): if streamoffset == current_span[1]: current_span[1] += segment.segment_size else: - stream_tokens.append("{0}:{1}:{2}".format(current_span[0], current_span[1] - current_span[0], fout)) + stream_tokens.append(u"{0}:{1}:{2}".format(current_span[0], current_span[1] - current_span[0], fout)) current_span = [streamoffset, streamoffset + segment.segment_size] if current_span is not None: - stream_tokens.append("{0}:{1}:{2}".format(current_span[0], current_span[1] - current_span[0], fout)) + stream_tokens.append(u"{0}:{1}:{2}".format(current_span[0], current_span[1] - current_span[0], fout)) if not stream[streamfile]: - stream_tokens.append("0:0:{0}".format(fout)) + stream_tokens.append(u"0:0:{0}".format(fout)) return stream_tokens