X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/33606c82797185fa65751f5724304f02605e0e05..3e157b65c2984537de1615c3fc8e41272d45ea69:/sdk/python/tests/test_stream.py diff --git a/sdk/python/tests/test_stream.py b/sdk/python/tests/test_stream.py index 11ee69493c..15257fe312 100644 --- a/sdk/python/tests/test_stream.py +++ b/sdk/python/tests/test_stream.py @@ -9,7 +9,8 @@ import unittest import hashlib import arvados -from arvados import StreamReader, StreamFileReader, Range +from arvados import StreamReader, StreamFileReader +from arvados._ranges import Range import arvados_testutil as tutil import run_test_server @@ -145,6 +146,20 @@ class StreamFileReaderTestCase(unittest.TestCase): self.assertEqual('nametest', sfile.name) self.assertEqual('nametest', sfile.name()) + def check_decompressed_name(self, filename, expect): + stream = tutil.MockStreamReader('.', '') + reader = StreamFileReader(stream, [Range(0, 0, 0)], filename) + self.assertEqual(expect, reader.decompressed_name()) + + def test_decompressed_name_uncompressed_file(self): + self.check_decompressed_name('test.log', 'test.log') + + def test_decompressed_name_gzip_file(self): + self.check_decompressed_name('test.log.gz', 'test.log') + + def test_decompressed_name_bz2_file(self): + self.check_decompressed_name('test.log.bz2', 'test.log') + def check_decompression(self, compress_ext, compress_func): test_text = 'decompression\ntest\n' test_data = compress_func(test_text)