Skip to content

Commit 63b3484

Browse files
committed
MOD: Reduce log level of end-of-interval msgs
1 parent dee7c64 commit 63b3484

2 files changed

Lines changed: 8 additions & 1 deletion

File tree

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
- `BLOCK_VOLUME`
1313
- `VENUE_SPECIFIC_VOLUME_1`
1414
- Added new publisher for Blue Ocean ATS (`OCEA_MEMOIR_OCEA`)
15+
- Reduced the log level of end-of-interval `SystemMsg` records to the debug level
1516

1617
## 0.69.0 - 2026-01-13
1718

databento/live/protocol.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
from databento_dbn import Metadata
1212
from databento_dbn import Schema
1313
from databento_dbn import SType
14+
from databento_dbn import SystemCode
1415
from databento_dbn import VersionUpgradePolicy
1516

1617
from databento.common import cram
@@ -388,7 +389,12 @@ def _process_dbn(self, data: bytes) -> None:
388389
if record.is_heartbeat():
389390
logger.debug("gateway heartbeat")
390391
else:
391-
logger.info(
392+
if record.code == SystemCode.END_OF_INTERVAL:
393+
system_msg_level = logging.DEBUG
394+
else:
395+
system_msg_level = logging.INFO
396+
logger.log(
397+
system_msg_level,
392398
"system message code=%s msg='%s'",
393399
record.code,
394400
record.msg,

0 commit comments

Comments
 (0)