FIX: Live client subscription batch size

Author: nmacholl

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## 0.24.1 - TBD
+
+#### Bug fixes
+- Fixed issue where a large unreadable symbol subscription message could be sent
+
 ## 0.24.0 - 2023-11-23
 
 This release adds support for DBN v2 as well as Python v3.12.

databento/live/protocol.py

@@ -33,7 +33,7 @@
 
 
 RECV_BUFFER_SIZE: Final = 64 * 2**10  # 64kb
-SYMBOL_LIST_BATCH_SIZE: Final = 64
+SYMBOL_LIST_BATCH_SIZE: Final = 32
 
 logger = logging.getLogger(__name__)
 

tests/test_live_client.py

@@ -427,27 +427,13 @@ async def test_live_subscribe_large_symbol_list(
         symbols=large_symbol_list,
     )
 
-    first_message = mock_live_server.get_message_of_type(
-        gateway.SubscriptionRequest,
-        timeout=1,
-    ).symbols.split(",")
-
-    second_message = mock_live_server.get_message_of_type(
-        gateway.SubscriptionRequest,
-        timeout=1,
-    ).symbols.split(",")
-
-    third_message = mock_live_server.get_message_of_type(
-        gateway.SubscriptionRequest,
-        timeout=1,
-    ).symbols.split(",")
-
-    fourth_message = mock_live_server.get_message_of_type(
-        gateway.SubscriptionRequest,
-        timeout=1,
-    ).symbols.split(",")
-
-    reconstructed = first_message + second_message + third_message + fourth_message
+    reconstructed: list[str] = []
+    for _ in range(8):
+        message = mock_live_server.get_message_of_type(
+            gateway.SubscriptionRequest,
+            timeout=1,
+        ).symbols.split(",")
+        reconstructed.extend(message)
 
     # Assert
     assert reconstructed == large_symbol_list