increases batch insert size to 50000 [ch2862]

Author: looselycoupled

btrdb/stream.py

@@ -33,7 +33,7 @@
 ## Module Variables
 ##########################################################################
 
-INSERT_BATCH_SIZE = 5000
+INSERT_BATCH_SIZE = 50000
 MINIMUM_TIME = -(16 << 56)
 MAXIMUM_TIME = (48 << 56) - 1
 

tests/btrdb/test_stream.py

@@ -727,15 +727,16 @@ def test_insert(self):
         """
         uu = uuid.UUID('0d22a53b-e2ef-4e0a-ab89-b2d48fb2592a')
         endpoint = Mock(Endpoint)
-        endpoint.insert = Mock(side_effect=[1,2])
+        endpoint.insert = Mock(side_effect=[1,2,3])
         stream = Stream(btrdb=BTrDB(endpoint), uuid=uu)
 
-        data = list(zip(range(10000,16000), map(float, range(6000))))
+        data = list(zip(range(10000,120000), map(float, range(110000))))
         version = stream.insert(data)
 
         assert stream._btrdb.ep.insert.call_args_list[0][0][1] == data[:INSERT_BATCH_SIZE]
-        assert stream._btrdb.ep.insert.call_args_list[1][0][1] == data[INSERT_BATCH_SIZE:]
-        assert version == 2
+        assert stream._btrdb.ep.insert.call_args_list[1][0][1] == data[INSERT_BATCH_SIZE:2*INSERT_BATCH_SIZE]
+        assert stream._btrdb.ep.insert.call_args_list[2][0][1] == data[2*INSERT_BATCH_SIZE:]
+        assert version == 3
 
 
     def test_nearest(self):