diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py index 79e5cbeb..53a5073d 100644 --- a/piker/brokers/binance/feed.py +++ b/piker/brokers/binance/feed.py @@ -102,12 +102,13 @@ class AggTrade(Struct, frozen=True): a: int # Aggregate trade ID p: float # Price q: float # Quantity with all the market trades - nq: float # Normal quantity without the trades involving RPI orders f: int # First trade ID l: int # noqa Last trade ID T: int # Trade time m: bool # Is the buyer the market maker? - M: bool | None = None # Ignore + M: bool|None = None # Ignore + nq: float|None = None # Normal quantity without the trades involving RPI orders + # ^XXX https://developers.binance.com/docs/derivatives/change-log#2025-12-29 async def stream_messages(