MOD: Reduce log level of SystemMsg

Author: nmacholl

CHANGELOG.md

@@ -12,6 +12,10 @@
   - Added `ts_index` and `pretty_ts_index` properties for records in Python which provides the timestamp that is most appropriate for indexing
   - Fixed type stub for `channel_id` to allow None
 
+#### Enhancements
+- Reduced the log level of `SystemMsg` records in the `Live` client to debug
+- Increased the log level of `SystemMsg` records with the code `SystemCode.SLOW_READER_WARNING` to warning
+
 #### Bug fixes
 - Fixed type hint for `start` parameter in `Live.subscribe()`
 

databento/live/protocol.py

@@ -7,9 +7,11 @@
 from typing import Final
 
 import databento_dbn
+from databento_dbn import DBNError
 from databento_dbn import Metadata
 from databento_dbn import Schema
 from databento_dbn import SType
+from databento_dbn import SystemCode
 from databento_dbn import VersionUpgradePolicy
 
 from databento.common import cram
@@ -380,10 +382,19 @@ def _process_dbn(self, data: bytes) -> None:
                     if record.is_heartbeat():
                         logger.debug("gateway heartbeat")
                     else:
-                        logger.info(
-                            "gateway message: %s",
-                            record.msg,
-                        )
+                        try:
+                            msg_code = record.code
+                        except DBNError:
+                            msg_code = None
+                        if msg_code == SystemCode.SLOW_READER_WARNING:
+                            logger.warning(
+                                record.msg,
+                            )
+                        else:
+                            logger.debug(
+                                "gateway message: %s",
+                                record.msg,
+                            )
                 self.received_record(record)
 
     def _process_gateway(self, data: bytes) -> None: