X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/93bc7c31775039cfb05be4caa0891f13fa49409f..e78607008c39aa88ccf6e95d7c6dfcc20a52a2ed:/sdk/python/tests/test_stream.py?ds=sidebyside

diff --git a/sdk/python/tests/test_stream.py b/sdk/python/tests/test_stream.py
index 2f4fc70097..dfff394aaf 100644
--- a/sdk/python/tests/test_stream.py
+++ b/sdk/python/tests/test_stream.py
@@ -272,151 +272,6 @@ class StreamFileReadAllDecompressedTestCase(StreamFileReadTestCase):
 class StreamFileReadlinesTestCase(StreamFileReadTestCase):
     def read_for_test(self, reader, byte_count, **kwargs):
         return ''.join(reader.readlines(**kwargs))
-
-# class StreamWriterTestCase(unittest.TestCase):
-#     class MockKeep(object):
-#         def __init__(self, blocks):
-#             self.blocks = blocks
-#         def get(self, locator, num_retries=0):
-#             return self.blocks[locator]
-#         def put(self, data):
-#             pdh = "%s+%i" % (hashlib.md5(data).hexdigest(), len(data))
-#             self.blocks[pdh] = str(data)
-#             return pdh
-
-#     def test_init(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         self.assertEqual("01234", stream.readfrom(0, 5))
-
-#     def test_append(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         self.assertEqual("56789", stream.readfrom(5, 8))
-#         stream.append("foo")
-#         self.assertEqual("56789foo", stream.readfrom(5, 8))
-
-
-# class StreamFileWriterTestCase(unittest.TestCase):
-#     def test_truncate(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("56789", writer.readfrom(5, 8))
-#         writer.truncate(8)
-#         self.assertEqual("567", writer.readfrom(5, 8))
-
-#     def test_append(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("56789", writer.readfrom(5, 8))
-#         writer.seek(10)
-#         writer.write("foo")
-#         self.assertEqual(writer.size(), 13)
-#         self.assertEqual("56789foo", writer.readfrom(5, 8))
-
-#     def test_write0(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("0123456789", writer.readfrom(0, 13))
-#         writer.seek(0)
-#         writer.write("foo")
-#         self.assertEqual(writer.size(), 10)
-#         self.assertEqual("foo3456789", writer.readfrom(0, 13))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 bufferblock0 10:3:count.txt 3:7:count.txt\n", stream.manifest_text())
-
-#     def test_write1(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("0123456789", writer.readfrom(0, 13))
-#         writer.seek(3)
-#         writer.write("foo")
-#         self.assertEqual(writer.size(), 10)
-#         self.assertEqual("012foo6789", writer.readfrom(0, 13))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 bufferblock0 0:3:count.txt 10:3:count.txt 6:4:count.txt\n", stream.manifest_text())
-
-#     def test_write2(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("0123456789", writer.readfrom(0, 13))
-#         writer.seek(7)
-#         writer.write("foo")
-#         self.assertEqual(writer.size(), 10)
-#         self.assertEqual("0123456foo", writer.readfrom(0, 13))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 bufferblock0 0:7:count.txt 10:3:count.txt\n", stream.manifest_text())
-
-#     def test_write3(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("012345678901234", writer.readfrom(0, 15))
-#         writer.seek(7)
-#         writer.write("foobar")
-#         self.assertEqual(writer.size(), 20)
-#         self.assertEqual("0123456foobar34", writer.readfrom(0, 15))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 bufferblock0 0:7:count.txt 10:6:count.txt 3:7:count.txt\n", stream.manifest_text())
-
-#     def test_write4(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:4:count.txt', '0:4:count.txt', '0:4:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         self.assertEqual("012301230123", writer.readfrom(0, 15))
-#         writer.seek(2)
-#         writer.write("abcdefg")
-#         self.assertEqual(writer.size(), 12)
-#         self.assertEqual("01abcdefg123", writer.readfrom(0, 15))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 bufferblock0 0:2:count.txt 10:7:count.txt 1:3:count.txt\n", stream.manifest_text())
-
-#     def test_write_large(self):
-#         stream = StreamWriter(['.', arvados.config.EMPTY_BLOCK_LOCATOR, '0:0:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({}))
-#         writer = stream.files()["count.txt"]
-#         text = ''.join(["0123456789" for a in xrange(0, 100)])
-#         for b in xrange(0, 100000):
-#             writer.write(text)
-#         self.assertEqual(writer.size(), 100000000)
-#         stream.commit()
-#         self.assertEqual(". a5de24f4417cfba9d5825eadc2f4ca49+67108000 598cc1a4ccaef8ab6e4724d87e675d78+32892000 0:100000000:count.txt\n", stream.manifest_text())
-
-#     def test_write_rewrite0(self):
-#         stream = StreamWriter(['.', arvados.config.EMPTY_BLOCK_LOCATOR, '0:0:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({}))
-#         writer = stream.files()["count.txt"]
-#         for b in xrange(0, 10):
-#             writer.seek(0, os.SEEK_SET)
-#             writer.write("0123456789")
-#         stream.commit()
-#         self.assertEqual(writer.size(), 10)
-#         self.assertEqual("0123456789", writer.readfrom(0, 20))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 0:10:count.txt\n", stream.manifest_text())
-
-#     def test_write_rewrite1(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         for b in xrange(0, 10):
-#             writer.seek(10, os.SEEK_SET)
-#             writer.write("abcdefghij")
-#         stream.commit()
-#         self.assertEqual(writer.size(), 20)
-#         self.assertEqual("0123456789abcdefghij", writer.readfrom(0, 20))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 a925576942e94b2ef57a066101b48876+10 0:10:count.txt 10:10:count.txt\n", stream.manifest_text())
-
-#     def test_write_rewrite2(self):
-#         stream = StreamWriter(['.', '781e5e245d69b566979b86e28d23f2c7+10', '0:10:count.txt'],
-#                               keep=StreamWriterTestCase.MockKeep({"781e5e245d69b566979b86e28d23f2c7+10": "0123456789"}))
-#         writer = stream.files()["count.txt"]
-#         for b in xrange(0, 10):
-#             writer.seek(5, os.SEEK_SET)
-#             writer.write("abcdefghij")
-#         stream.commit()
-#         self.assertEqual(writer.size(), 15)
-#         self.assertEqual("01234abcdefghij", writer.readfrom(0, 20))
-#         self.assertEqual(". 781e5e245d69b566979b86e28d23f2c7+10 a925576942e94b2ef57a066101b48876+10 0:5:count.txt 10:10:count.txt\n", stream.manifest_text())
-
+o
 if __name__ == '__main__':
     unittest.main()